-
Notifications
You must be signed in to change notification settings - Fork 3.2k
Description
Using the librdkafka++-2.8.0 version and latest kafka server,
Observing whenever consumer callse consume(1000) randomly genrating the core.
Implementationwise, single process has 3 consumer thread and 3 produce threads per topic and each topic have 3 partitions.
TID 133448:
#0 0x00007f6fc4a62f22 __waitpid - /usr/lib64/libc-2.28.so
#1 0x00007f6fc49b6747 - 1 do_system - /usr/lib64/libc-2.28.so
#2 0x00007f6fc7565564 - 1 sighdl_handler - /opt/SMAW/INTP/install/IMSPimslb/linking/lib64/impl/libsignalhandler.so
#3 0x00007f6fc7356990 __restore_rt - /usr/lib64/libpthread-2.28.so
#4 0x0000000000000211
#5 0x0000000000428020 - 1 void std::__invoke_impl<void, void (self::selfConsumer::)(), self::selfConsumer>(std::__invoke_memfun_deref, void (self::selfConsumer::&&)(), self::selfConsumer&&) - /opt/SMAW/INTP/install/IMSPimslb/bin64/self
/usr/include/c++/8/bits/invoke.h:73:46
#6 0x0000000000427144 - 1 std::__invoke_result<void (self::selfConsumer::)(), self::selfConsumer>::type std::__invoke<void (self::selfConsumer::)(), self::selfConsumer>(void (self::selfConsumer::&&)(), self::selfConsumer&&) - /opt/SMAW/INTP/install/IMSPimslb/bin64/self
/usr/include/c++/8/bits/invoke.h:95:40
#7 0x0000000000429579 - 1 decltype (__invoke((_S_declval<0ul>)(), (_S_declval<1ul>)())) std::thread::_Invoker<std::tuple<void (self::selfConsumer::)(), self::selfConsumer> >::_M_invoke<0ul, 1ul>(std::_Index_tuple<0ul, 1ul>) - /opt/SMAW/INTP/install/IMSPimslb/bin64/self
/usr/include/c++/8/thread:244:26
#8 0x000000000042951a - 1 std::thread::_Invoker<std::tuple<void (self::selfConsumer::)(), self::selfConsumer> >::operator()() - /opt/SMAW/INTP/install/IMSPimslb/bin64/self
/usr/include/c++/8/thread:253:31
#9 0x00000000004294de - 1 std::thread::_State_impl<std::thread::_Invoker<std::tuple<void (self::selfConsumer::)(), self::selfConsumer> > >::_M_run() - /opt/SMAW/INTP/install/IMSPimslb/bin64/self
/usr/include/c++/8/thread:196:13
#10 0x00007f6fc9b09b23 - 1 execute_native_thread_routine - /usr/lib64/libstdc++.so.6.0.25
#11 0x00007f6fc734c1ca - 1 start_thread - /usr/lib64/libpthread-2.28.so
#12 0x00007f6fc49948d3 - 1 __clone - /usr/lib64/libc-2.28.so
Anybody faced this issue or help me on this ?