TCPHandler      14      fa60f5f6-a60a-48f3-b137-b56d8b1ae093    __futex_abstimed_wait_cancelable64
pthread_cond_wait@@GLIBC_2.3.2
rd_kafka_cnd_wait
rd_kafka_q_pop_serve
rd_kafka_op_req
rd_kafka_assign
cppkafka::Consumer::assign(std::__1::vector<cppkafka::TopicPartition, std::__1::allocator<cppkafka::TopicPartition>> const&)
cppkafka::Consumer::handle_rebalance(rd_kafka_resp_err_t, std::__1::vector<cppkafka::TopicPartition, std::__1::allocator<cppkafka::TopicPartition>>&)
cppkafka::Consumer::rebalance_proxy(rd_kafka_s*, rd_kafka_resp_err_t, rd_kafka_topic_partition_list_s*, void*)
rd_kafka_poll_cb
rd_kafka_consumer_close
cppkafka::Consumer::~Consumer()
DB::StorageKafka::cleanConsumers()
DB::StorageKafka::shutdown(bool)
DB::InterpreterDropQuery::executeToTableImpl(std::__1::shared_ptr<DB::Context const> const&, DB::ASTDropQuery&, std::__1::shared_ptr<DB::IDatabase>&, StrongTypedef<wide::integer<128ul, unsigned int>, DB::UUIDTag>&)
DB::InterpreterDropQuery::executeToTable(DB::ASTDropQuery&)
DB::InterpreterDropQuery::executeSingleDropQuery(boost::intrusive_ptr<DB::IAST> const&)
DB::InterpreterDropQuery::execute()
DB::executeQueryImpl(char const*, char const*, std::__1::shared_ptr<DB::Context>, DB::QueryFlags, DB::QueryProcessingStage::Enum, std::__1::unique_ptr<DB::ReadBuffer, std::__1::default_delete<DB::ReadBuffer>>&, boost::intrusive_ptr<DB::IAST>&, std::__1::shared_ptr<DB::ImplicitTransactionContro>
DB::executeQuery(std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char>> const&, std::__1::shared_ptr<DB::Context>, DB::QueryFlags, DB::QueryProcessingStage::Enum)
DB::TCPHandler::runImpl()
DB::TCPHandler::run()
Poco::Net::TCPServerConnection::start()
Poco::Net::TCPServerDispatcher::run()
Poco::PooledThread::run()
Poco::ThreadImpl::runnableEntry(void*)
start_thread
__GI___clone3