2025.05.22 07:18:42.642441 [ 84 ] {8585aac2-7690-4514-bbee-68e219868062} <Error> executeQuery: Code: 1001. DB::Exception: cppkafka::HandleException: Local: Unknown group. (STD_EXCEPTION) (version 25.1.5.31 (official build)) (from 127.0.0.1:52142) (query 1, line 1) (in query: SELECT * FROM dummy_http_logs_test LIMIT 10 SETTINGS stream_like_engine_allow_direct_select=1;), Stack trace (when copying this message, always include the lines below):

0. cppkafka::Consumer::get_subscription() const @ 0x0000000017127cd6
1. DB::KafkaConsumer::subscribe() @ 0x000000001108ca5c
2. DB::KafkaSource::generateImpl() @ 0x00000000110f87b1
3. DB::KafkaSource::generate() @ 0x00000000110fc40f
4. DB::ISource::tryGenerate() @ 0x0000000013f13afb
5. DB::ISource::work() @ 0x0000000013f137e7
6. DB::ExecutionThreadContext::executeTask() @ 0x0000000013f2fa47
7. DB::PipelineExecutor::executeStepImpl(unsigned long, std::atomic<bool>*) @ 0x0000000013f226e4
8. DB::PipelineExecutor::execute(unsigned long, bool) @ 0x0000000013f2199e
9. void std::__function::__policy_invoker<void ()>::__call_impl[abi:ne180100]<std::__function::__default_alloc_func<ThreadFromGlobalPoolImpl<true, true>::ThreadFromGlobalPoolImpl<DB::PullingAsyncPipelineExecutor::pull(DB::Chunk&, unsigned long)::$_0>(DB::PullingAsyncPipelineExecutor::pull(DB::Chunk&, unsigned long)::$_0&&)::'lambda'(), void ()>>(std::__function::__policy_storage const*) @ 0x0000000013f331d2
10. ThreadPoolImpl<std::thread>::ThreadFromThreadPool::worker() @ 0x000000000ddead7f
11. void* std::__thread_proxy[abi:ne180100]<std::tuple<std::unique_ptr<std::__thread_struct, std::default_delete<std::__thread_struct>>, void (ThreadPoolImpl<std::thread>::ThreadFromThreadPool::*)(), ThreadPoolImpl<std::thread>::ThreadFromThreadPool*>>(void*) @ 0x000000000ddf1efa
12. ? @ 0x00007b01bc05dac3
13. ? @ 0x00007b01bc0eea04


2025.05.22 07:19:42.997696 [ 813 ] {} <Fatal> BaseDaemon: ########## Short fault info ############
2025.05.22 07:19:42.997746 [ 813 ] {} <Fatal> BaseDaemon: (version 25.1.5.31 (official build), build id: 28E55A67E083A6497229FC977904A62169BEBCE0, git hash: 48f17e8a805c167a91a343975ad04c1555ad901d, architecture: x86_64) (from thread 766) Received signal 11
2025.05.22 07:19:42.997786 [ 813 ] {} <Fatal> BaseDaemon: Signal description: Segmentation fault
2025.05.22 07:19:42.997805 [ 813 ] {} <Fatal> BaseDaemon: Address: NULL pointer. Access: read. Address not mapped to object.
2025.05.22 07:19:42.997827 [ 813 ] {} <Fatal> BaseDaemon: Stack trace: 0x000000000e0862d5 0x00007b01bc00b520 0x00007b01bc1667fe 0x0000000017127dbf 0x00000000110a41af 0x000000000ddead7f 0x000000000ddf1efa 0x00007b01bc05dac3 0x00007b01bc0eea04
2025.05.22 07:19:42.997846 [ 813 ] {} <Fatal> BaseDaemon: ########################################
2025.05.22 07:19:42.997862 [ 813 ] {} <Fatal> BaseDaemon: (version 25.1.5.31 (official build), build id: 28E55A67E083A6497229FC977904A62169BEBCE0, git hash: 48f17e8a805c167a91a343975ad04c1555ad901d) (from thread 766) (no query) Received signal Segmentation fault (11)
2025.05.22 07:19:42.997879 [ 813 ] {} <Fatal> BaseDaemon: Address: NULL pointer. Access: read. Address not mapped to object.
2025.05.22 07:19:42.997892 [ 813 ] {} <Fatal> BaseDaemon: Stack trace: 0x000000000e0862d5 0x00007b01bc00b520 0x00007b01bc1667fe 0x0000000017127dbf 0x00000000110a41af 0x000000000ddead7f 0x000000000ddf1efa 0x00007b01bc05dac3 0x00007b01bc0eea04
2025.05.22 07:19:42.997950 [ 813 ] {} <Fatal> BaseDaemon: 0. signalHandler(int, siginfo_t*, void*) @ 0x000000000e0862d5
2025.05.22 07:19:42.997970 [ 813 ] {} <Fatal> BaseDaemon: 1. ? @ 0x00007b01bc00b520
2025.05.22 07:19:42.997986 [ 813 ] {} <Fatal> BaseDaemon: 2. ? @ 0x00007b01bc1667fe
2025.05.22 07:19:42.998015 [ 813 ] {} <Fatal> BaseDaemon: 3. cppkafka::Consumer::get_member_id() const @ 0x0000000017127dbf
2025.05.22 07:19:42.998068 [ 813 ] {} <Fatal> BaseDaemon: 4. void std::__function::__policy_invoker<void ()>::__call_impl[abi:ne180100]<std::__function::__default_alloc_func<ThreadFromGlobalPoolImpl<true, true>::ThreadFromGlobalPoolImpl<DB::StorageKafka::StorageKafka(DB::StorageID const&, std::shared_ptr<DB::Context const>, DB::ColumnsDescription const&, String const&, std::unique_ptr<DB::KafkaSettings, std::default_delete<DB::KafkaSettings>>, String const&)::$_0>(DB::StorageKafka::StorageKafka(DB::StorageID const&, std::shared_ptr<DB::Context const>, DB::ColumnsDescription const&, String const&, std::unique_ptr<DB::KafkaSettings, std::default_delete<DB::KafkaSettings>>, String const&)::$_0&&)::'lambda'(), void ()>>(std::__function::__policy_storage const*) @ 0x00000000110a41af
2025.05.22 07:19:42.998101 [ 813 ] {} <Fatal> BaseDaemon: 5. ThreadPoolImpl<std::thread>::ThreadFromThreadPool::worker() @ 0x000000000ddead7f
2025.05.22 07:19:42.998127 [ 813 ] {} <Fatal> BaseDaemon: 6. void* std::__thread_proxy[abi:ne180100]<std::tuple<std::unique_ptr<std::__thread_struct, std::default_delete<std::__thread_struct>>, void (ThreadPoolImpl<std::thread>::ThreadFromThreadPool::*)(), ThreadPoolImpl<std::thread>::ThreadFromThreadPool*>>(void*) @ 0x000000000ddf1efa
2025.05.22 07:19:42.998146 [ 813 ] {} <Fatal> BaseDaemon: 7. ? @ 0x00007b01bc05dac3
2025.05.22 07:19:42.998161 [ 813 ] {} <Fatal> BaseDaemon: 8. ? @ 0x00007b01bc0eea04
2025.05.22 07:19:43.140162 [ 813 ] {} <Fatal> BaseDaemon: Integrity check of the executable successfully passed (checksum: B315C7B01FA03C5E3F65D78CC8863D5F)
2025.05.22 07:19:43.140301 [ 813 ] {} <Fatal> BaseDaemon: Report this error to https://github.com/ClickHouse/ClickHouse/issues

KfkCln:dummy_ht[321311]: segfault at 0 ip 00007b01bc1667fd sp 00007affcfbf7cc8 error 4 in libc.so.6[7b01bbff1000+195000] likely on CPU 3 (core 3, socket 0)

CREATE OR REPLACE NAMED COLLECTION kafka_config AS
    kafka_broker_list = 'localhost:9092';

CREATE TABLE dummy_http_logs_test 
(
    raw_message String
) engine=Kafka(kafka_config)
SETTTINGS kafka_topic_list='dummy_http_logs_test', kafka_format='RawBLOB';