Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Hangs on rd_kafka_flush #999

Closed
greatt1n opened this issue Jan 16, 2017 · 1 comment
Closed

Hangs on rd_kafka_flush #999

greatt1n opened this issue Jan 16, 2017 · 1 comment

Comments

@greatt1n
Copy link

Hi,enenhill,
I found my program hangs on rd_kafka_flush() servel times,timesout_ms is 1000.I am using rdkafka 0.9.2,below is pstack log.

Thread 123 (Thread 0x7ff2a6c12700 (LWP 6479)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2accf9d02 in do_io (v=0x194b990) at src/mt_adaptor.c:387
#2 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#3 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 122 (Thread 0x7ff2a6411700 (LWP 6480)):
#0 0x00007ff2aa07e6d5 in pthread_cond_wait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2accf9e4b in do_completion (v=0x194b990) at src/mt_adaptor.c:463
#2 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#3 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 121 (Thread 0x7ff2a5c10700 (LWP 6481)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x194d118, mtx=mtx@entry=0x194d0f0, timeout_ms=) at tinycthread.c:501
#2 0x00007ff2ad22d336 in rd_kafka_q_serve (rkq=0x194d0f0, timeout_ms=, max_cnt=max_cnt@entry=0, cb_type=cb_type@entry=1, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:401
#3 0x00007ff2ad20c9ac in rd_kafka_thread_main (arg=arg@entry=0x1983d50) at rdkafka.c:1112
#4 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#5 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#6 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 120 (Thread 0x7ff2a540f700 (LWP 6482)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x1984da8, mtx=mtx@entry=0x1984d80, timeout_ms=timeout_ms@entry=10) at tinycthread.c:501
#2 0x00007ff2ad22d0ee in rd_kafka_q_pop_serve (rkq=0x1984d80, timeout_ms=timeout_ms@entry=10, version=version@entry=0, cb_type=cb_type@entry=2, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:321
#3 0x00007ff2ad22d230 in rd_kafka_q_pop (rkq=, timeout_ms=timeout_ms@entry=10, version=version@entry=0) at rdkafka_queue.c:354
#4 0x00007ff2ad21adc8 in rd_kafka_broker_serve (rkb=rkb@entry=0x1984670, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3093
#5 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x1984670, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#6 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x1984670) at rdkafka_broker.c:4499
#7 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#8 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#9 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 119 (Thread 0x7ff2a4c0e700 (LWP 6483)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2940009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2940009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x1985120, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x1985120, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x1985120) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 118 (Thread 0x7ff29ffff700 (LWP 6484)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff28c0009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff28c0009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x1985bb0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x1985bb0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x1985bb0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 117 (Thread 0x7ff29f7fe700 (LWP 6485)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2900009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2900009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x1986640, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x1986640, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x1986640) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 116 (Thread 0x7ff29effd700 (LWP 6486)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2840009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2840009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x19870f0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x19870f0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x19870f0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 115 (Thread 0x7ff29e7fc700 (LWP 6487)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2880009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2880009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x1987b00, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x1987b00, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x1987b00) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 114 (Thread 0x7ff29dffb700 (LWP 6488)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x1989398, mtx=mtx@entry=0x1989370, timeout_ms=) at tinycthread.c:501
#2 0x00007ff2ad22d336 in rd_kafka_q_serve (rkq=0x1989370, timeout_ms=, max_cnt=max_cnt@entry=0, cb_type=cb_type@entry=1, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:401
#3 0x00007ff2ad20c9ac in rd_kafka_thread_main (arg=arg@entry=0x19894d0) at rdkafka.c:1112
#4 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#5 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#6 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 113 (Thread 0x7ff29d7fa700 (LWP 6489)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x198a588, mtx=mtx@entry=0x198a560, timeout_ms=timeout_ms@entry=10) at tinycthread.c:501
#2 0x00007ff2ad22d0ee in rd_kafka_q_pop_serve (rkq=0x198a560, timeout_ms=timeout_ms@entry=10, version=version@entry=0, cb_type=cb_type@entry=2, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:321
#3 0x00007ff2ad22d230 in rd_kafka_q_pop (rkq=, timeout_ms=timeout_ms@entry=10, version=version@entry=0) at rdkafka_queue.c:354
#4 0x00007ff2ad21adc8 in rd_kafka_broker_serve (rkb=rkb@entry=0x1989e50, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3093
#5 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x1989e50, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#6 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x1989e50) at rdkafka_broker.c:4499
#7 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#8 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#9 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 112 (Thread 0x7ff29cff9700 (LWP 6490)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff27c0009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff27c0009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x198a900, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x198a900, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x198a900) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 111 (Thread 0x7ff283fff700 (LWP 6491)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2740009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2740009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x198b390, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x198b390, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x198b390) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 110 (Thread 0x7ff2837fe700 (LWP 6492)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2700009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2700009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x198be20, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x198be20, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x198be20) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 109 (Thread 0x7ff282ffd700 (LWP 6493)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2780009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2780009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x198c8b0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x198c8b0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x198c8b0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 108 (Thread 0x7ff2827fc700 (LWP 6494)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff26c0009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff26c0009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x198d360, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x198d360, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x198d360) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 107 (Thread 0x7ff281ffb700 (LWP 6495)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff268000a10, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff268000a10, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff264001130, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff264001130) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 106 (Thread 0x7ff2817fa700 (LWP 6496)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff25c0009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff25c0009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff264001bd0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff264001bd0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 105 (Thread 0x7ff280ff9700 (LWP 6497)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff24c0009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff24c0009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff264002650, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff264002650) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 104 (Thread 0x7ff263fff700 (LWP 6498)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2580009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2580009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff2640030f0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff2640030f0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 103 (Thread 0x7ff2637fe700 (LWP 6499)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2500009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2500009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff264003b50, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff264003b50) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 102 (Thread 0x7ff262ffd700 (LWP 6500)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2440009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2440009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff254001130, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff254001130) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 101 (Thread 0x7ff2627fc700 (LWP 6501)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2480009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2480009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff254001bd0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff254001bd0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 100 (Thread 0x7ff261ffb700 (LWP 6502)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff23c0009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff23c0009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff254002650, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff254002650) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 99 (Thread 0x7ff2617fa700 (LWP 6503)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2400009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2400009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff2540030d0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff2540030d0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 98 (Thread 0x7ff260ff9700 (LWP 6504)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2340009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2340009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff254003b50, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff254003b50) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 97 (Thread 0x7ff23bfff700 (LWP 6508)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68a2988, mtx=mtx@entry=0x68a2960, timeout_ms=) at tinycthread.c:501
#2 0x00007ff2ad22d336 in rd_kafka_q_serve (rkq=0x68a2960, timeout_ms=, max_cnt=max_cnt@entry=0, cb_type=cb_type@entry=1, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:401
#3 0x00007ff2ad20c9ac in rd_kafka_thread_main (arg=arg@entry=0x68a3070) at rdkafka.c:1112
#4 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#5 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#6 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 96 (Thread 0x7ff23b7fe700 (LWP 6509)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68a4408, mtx=mtx@entry=0x68a43e0, timeout_ms=timeout_ms@entry=10) at tinycthread.c:501
#2 0x00007ff2ad22d0ee in rd_kafka_q_pop_serve (rkq=0x68a43e0, timeout_ms=timeout_ms@entry=10, version=version@entry=0, cb_type=cb_type@entry=2, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:321
#3 0x00007ff2ad22d230 in rd_kafka_q_pop (rkq=, timeout_ms=timeout_ms@entry=10, version=version@entry=0) at rdkafka_queue.c:354
#4 0x00007ff2ad21adc8 in rd_kafka_broker_serve (rkb=rkb@entry=0x68a3d10, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3093
#5 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68a3d10, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#6 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68a3d10) at rdkafka_broker.c:4499
#7 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#8 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#9 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 95 (Thread 0x7ff23affd700 (LWP 6510)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2280009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2280009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68a4740, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68a4740, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68a4740) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 94 (Thread 0x7ff23a7fc700 (LWP 6511)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2200009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2200009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68a51f0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68a51f0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68a51f0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 93 (Thread 0x7ff239ffb700 (LWP 6512)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2180009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2180009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68a5c60, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68a5c60, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68a5c60) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 92 (Thread 0x7ff2397fa700 (LWP 6513)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff2100009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff2100009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68a66f0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68a66f0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68a66f0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 91 (Thread 0x7ff238ff9700 (LWP 6514)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff21c0009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff21c0009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68a7180, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68a7180, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68a7180) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 90 (Thread 0x7ff22cbd6700 (LWP 6515)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68a7ee8, mtx=mtx@entry=0x68a7ec0, timeout_ms=) at tinycthread.c:501
#2 0x00007ff2ad22d336 in rd_kafka_q_serve (rkq=0x68a7ec0, timeout_ms=, max_cnt=max_cnt@entry=0, cb_type=cb_type@entry=1, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:401
#3 0x00007ff2ad20c9ac in rd_kafka_thread_main (arg=arg@entry=0x68a8050) at rdkafka.c:1112
#4 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#5 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#6 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 89 (Thread 0x7ff217fff700 (LWP 6516)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68a8fe8, mtx=mtx@entry=0x68a8fc0, timeout_ms=timeout_ms@entry=10) at tinycthread.c:501
#2 0x00007ff2ad22d0ee in rd_kafka_q_pop_serve (rkq=0x68a8fc0, timeout_ms=timeout_ms@entry=10, version=version@entry=0, cb_type=cb_type@entry=2, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:321
#3 0x00007ff2ad22d230 in rd_kafka_q_pop (rkq=, timeout_ms=timeout_ms@entry=10, version=version@entry=0) at rdkafka_queue.c:354
#4 0x00007ff2ad21adc8 in rd_kafka_broker_serve (rkb=rkb@entry=0x68a88f0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3093
#5 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68a88f0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#6 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68a88f0) at rdkafka_broker.c:4499
#7 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#8 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#9 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 88 (Thread 0x7ff2177fe700 (LWP 6517)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff204000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff204000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68a9300, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68a9300, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68a9300) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 87 (Thread 0x7ff216ffd700 (LWP 6518)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff208000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff208000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68a9d40, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68a9d40, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68a9d40) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 86 (Thread 0x7ff2167fc700 (LWP 6519)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff200000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff200000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68aa7a0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68aa7a0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68aa7a0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 85 (Thread 0x7ff215ffb700 (LWP 6520)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1fc000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1fc000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68ab1e0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68ab1e0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68ab1e0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 84 (Thread 0x7ff2157fa700 (LWP 6521)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1f4000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1f4000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68abc40, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68abc40, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68abc40) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 83 (Thread 0x7ff214ff9700 (LWP 6522)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68acf68, mtx=mtx@entry=0x68acf40, timeout_ms=) at tinycthread.c:501
#2 0x00007ff2ad22d336 in rd_kafka_q_serve (rkq=0x68acf40, timeout_ms=, max_cnt=max_cnt@entry=0, cb_type=cb_type@entry=1, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:401
#3 0x00007ff2ad20c9ac in rd_kafka_thread_main (arg=arg@entry=0x68ad180) at rdkafka.c:1112
#4 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#5 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#6 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 82 (Thread 0x7ff1fbfff700 (LWP 6523)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68ae138, mtx=mtx@entry=0x68ae110, timeout_ms=timeout_ms@entry=10) at tinycthread.c:501
#2 0x00007ff2ad22d0ee in rd_kafka_q_pop_serve (rkq=0x68ae110, timeout_ms=timeout_ms@entry=10, version=version@entry=0, cb_type=cb_type@entry=2, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:321
#3 0x00007ff2ad22d230 in rd_kafka_q_pop (rkq=, timeout_ms=timeout_ms@entry=10, version=version@entry=0) at rdkafka_queue.c:354
#4 0x00007ff2ad21adc8 in rd_kafka_broker_serve (rkb=rkb@entry=0x68ada20, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3093
#5 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68ada20, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#6 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68ada20) at rdkafka_broker.c:4499
#7 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#8 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#9 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 81 (Thread 0x7ff1fb7fe700 (LWP 6524)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1ec000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1ec000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68ae4d0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68ae4d0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68ae4d0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 80 (Thread 0x7ff1faffd700 (LWP 6525)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1e4000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1e4000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68aef60, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68aef60, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68aef60) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 79 (Thread 0x7ff1fa7fc700 (LWP 6526)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1dc000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1dc000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68afa10, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68afa10, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68afa10) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 78 (Thread 0x7ff1f9ffb700 (LWP 6527)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1e8000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1e8000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68b0480, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b0480, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b0480) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 77 (Thread 0x7ff1f97fa700 (LWP 6528)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1e0000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1e0000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68b0f10, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b0f10, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b0f10) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 76 (Thread 0x7ff1f8ff9700 (LWP 6529)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68b2358, mtx=mtx@entry=0x68b2330, timeout_ms=) at tinycthread.c:501
#2 0x00007ff2ad22d336 in rd_kafka_q_serve (rkq=0x68b2330, timeout_ms=, max_cnt=max_cnt@entry=0, cb_type=cb_type@entry=1, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:401
#3 0x00007ff2ad20c9ac in rd_kafka_thread_main (arg=arg@entry=0x68b24b0) at rdkafka.c:1112
#4 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#5 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#6 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 75 (Thread 0x7ff1dbfff700 (LWP 6530)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68b3448, mtx=mtx@entry=0x68b3420, timeout_ms=timeout_ms@entry=10) at tinycthread.c:501
#2 0x00007ff2ad22d0ee in rd_kafka_q_pop_serve (rkq=0x68b3420, timeout_ms=timeout_ms@entry=10, version=version@entry=0, cb_type=cb_type@entry=2, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:321
#3 0x00007ff2ad22d230 in rd_kafka_q_pop (rkq=, timeout_ms=timeout_ms@entry=10, version=version@entry=0) at rdkafka_queue.c:354
#4 0x00007ff2ad21adc8 in rd_kafka_broker_serve (rkb=rkb@entry=0x68b2d50, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3093
#5 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b2d50, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#6 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b2d50) at rdkafka_broker.c:4499
#7 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#8 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#9 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 74 (Thread 0x7ff1db7fe700 (LWP 6531)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1cc000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1cc000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68b37e0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b37e0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b37e0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 73 (Thread 0x7ff1daffd700 (LWP 6532)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1d0000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1d0000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68b4270, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b4270, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b4270) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 72 (Thread 0x7ff1da7fc700 (LWP 6533)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1c4000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1c4000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68b4d00, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b4d00, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b4d00) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 71 (Thread 0x7ff1d9ffb700 (LWP 6534)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1c8000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1c8000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68b5790, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b5790, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b5790) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 70 (Thread 0x7ff1d97fa700 (LWP 6535)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1bc000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1bc000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68b6220, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b6220, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b6220) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 69 (Thread 0x7ff1d8ff9700 (LWP 6536)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68b7568, mtx=mtx@entry=0x68b7540, timeout_ms=) at tinycthread.c:501
#2 0x00007ff2ad22d336 in rd_kafka_q_serve (rkq=0x68b7540, timeout_ms=, max_cnt=max_cnt@entry=0, cb_type=cb_type@entry=1, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:401
#3 0x00007ff2ad20c9ac in rd_kafka_thread_main (arg=arg@entry=0x68b77a0) at rdkafka.c:1112
#4 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#5 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#6 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 68 (Thread 0x7ff1c3fff700 (LWP 6537)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68b8738, mtx=mtx@entry=0x68b8710, timeout_ms=timeout_ms@entry=10) at tinycthread.c:501
#2 0x00007ff2ad22d0ee in rd_kafka_q_pop_serve (rkq=0x68b8710, timeout_ms=timeout_ms@entry=10, version=version@entry=0, cb_type=cb_type@entry=2, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:321
#3 0x00007ff2ad22d230 in rd_kafka_q_pop (rkq=, timeout_ms=timeout_ms@entry=10, version=version@entry=0) at rdkafka_queue.c:354
#4 0x00007ff2ad21adc8 in rd_kafka_broker_serve (rkb=rkb@entry=0x68b8040, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3093
#5 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b8040, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#6 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b8040) at rdkafka_broker.c:4499
#7 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#8 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#9 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 67 (Thread 0x7ff1c37fe700 (LWP 6538)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1b0000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1b0000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68b8ad0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b8ad0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b8ad0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 66 (Thread 0x7ff1c2ffd700 (LWP 6539)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1b4000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1b4000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68b9540, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b9540, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b9540) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 65 (Thread 0x7ff1c27fc700 (LWP 6540)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1a8000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1a8000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68b9fd0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68b9fd0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68b9fd0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 64 (Thread 0x7ff1c1ffb700 (LWP 6541)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1ac000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1ac000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68baa60, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68baa60, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68baa60) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 63 (Thread 0x7ff1c17fa700 (LWP 6542)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1a0000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1a0000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68bb510, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68bb510, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68bb510) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 62 (Thread 0x7ff1c0ff9700 (LWP 6543)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68bc8d8, mtx=mtx@entry=0x68bc8b0, timeout_ms=) at tinycthread.c:501
#2 0x00007ff2ad22d336 in rd_kafka_q_serve (rkq=0x68bc8b0, timeout_ms=, max_cnt=max_cnt@entry=0, cb_type=cb_type@entry=1, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:401
#3 0x00007ff2ad20c9ac in rd_kafka_thread_main (arg=arg@entry=0x68bca50) at rdkafka.c:1112
#4 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#5 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#6 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 61 (Thread 0x7ff1a7fff700 (LWP 6544)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68bda48, mtx=mtx@entry=0x68bda20, timeout_ms=timeout_ms@entry=10) at tinycthread.c:501
#2 0x00007ff2ad22d0ee in rd_kafka_q_pop_serve (rkq=0x68bda20, timeout_ms=timeout_ms@entry=10, version=version@entry=0, cb_type=cb_type@entry=2, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:321
#3 0x00007ff2ad22d230 in rd_kafka_q_pop (rkq=, timeout_ms=timeout_ms@entry=10, version=version@entry=0) at rdkafka_queue.c:354
#4 0x00007ff2ad21adc8 in rd_kafka_broker_serve (rkb=rkb@entry=0x68bd310, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3093
#5 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68bd310, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#6 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68bd310) at rdkafka_broker.c:4499
#7 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#8 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#9 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 60 (Thread 0x7ff1a77fe700 (LWP 6545)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff194000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff194000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68bdde0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68bdde0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68bdde0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 59 (Thread 0x7ff1a6ffd700 (LWP 6546)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff198000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff198000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68be870, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68be870, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68be870) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 58 (Thread 0x7ff1a67fc700 (LWP 6547)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff18c000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff18c000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68bf2e0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68bf2e0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68bf2e0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 57 (Thread 0x7ff1a5ffb700 (LWP 6548)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff190000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff190000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68bfd70, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68bfd70, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68bfd70) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 56 (Thread 0x7ff1a57fa700 (LWP 6549)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff184000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff184000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68c0800, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68c0800, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68c0800) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 55 (Thread 0x7ff1a4ff9700 (LWP 6550)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68c1b68, mtx=mtx@entry=0x68c1b40, timeout_ms=) at tinycthread.c:501
#2 0x00007ff2ad22d336 in rd_kafka_q_serve (rkq=0x68c1b40, timeout_ms=, max_cnt=max_cnt@entry=0, cb_type=cb_type@entry=1, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:401
#3 0x00007ff2ad20c9ac in rd_kafka_thread_main (arg=arg@entry=0x68c1d80) at rdkafka.c:1112
#4 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#5 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#6 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 54 (Thread 0x7ff18bfff700 (LWP 6551)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68c2d58, mtx=mtx@entry=0x68c2d30, timeout_ms=timeout_ms@entry=10) at tinycthread.c:501
#2 0x00007ff2ad22d0ee in rd_kafka_q_pop_serve (rkq=0x68c2d30, timeout_ms=timeout_ms@entry=10, version=version@entry=0, cb_type=cb_type@entry=2, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:321
#3 0x00007ff2ad22d230 in rd_kafka_q_pop (rkq=, timeout_ms=timeout_ms@entry=10, version=version@entry=0) at rdkafka_queue.c:354
#4 0x00007ff2ad21adc8 in rd_kafka_broker_serve (rkb=rkb@entry=0x68c2620, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3093
#5 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68c2620, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#6 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68c2620) at rdkafka_broker.c:4499
#7 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#8 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#9 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 53 (Thread 0x7ff18b7fe700 (LWP 6552)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff178000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff178000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68c30f0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68c30f0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68c30f0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 52 (Thread 0x7ff18affd700 (LWP 6553)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff17c000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff17c000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68c3b80, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68c3b80, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68c3b80) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 51 (Thread 0x7ff18a7fc700 (LWP 6554)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x68c6450, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x68c6450, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68c4610, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68c4610, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68c4610) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 50 (Thread 0x7ff189ffb700 (LWP 6555)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff17c000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff17c000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68c5080, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68c5080, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68c5080) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 49 (Thread 0x7ff1897fa700 (LWP 6556)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff178000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff178000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68c5c20, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68c5c20, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68c5c20) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 48 (Thread 0x7ff188ff9700 (LWP 6557)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68c6f18, mtx=mtx@entry=0x68c6ef0, timeout_ms=) at tinycthread.c:501
#2 0x00007ff2ad22d336 in rd_kafka_q_serve (rkq=0x68c6ef0, timeout_ms=, max_cnt=max_cnt@entry=0, cb_type=cb_type@entry=1, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:401
#3 0x00007ff2ad20c9ac in rd_kafka_thread_main (arg=arg@entry=0x68c7170) at rdkafka.c:1112
#4 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#5 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#6 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 47 (Thread 0x7ff177fff700 (LWP 6558)):
#0 0x00007ff2aa07ea82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007ff2ad24e2e5 in cnd_timedwait_ms (cnd=cnd@entry=0x68c8108, mtx=mtx@entry=0x68c80e0, timeout_ms=timeout_ms@entry=10) at tinycthread.c:501
#2 0x00007ff2ad22d0ee in rd_kafka_q_pop_serve (rkq=0x68c80e0, timeout_ms=timeout_ms@entry=10, version=version@entry=0, cb_type=cb_type@entry=2, callback=callback@entry=0x0, opaque=opaque@entry=0x0) at rdkafka_queue.c:321
#3 0x00007ff2ad22d230 in rd_kafka_q_pop (rkq=, timeout_ms=timeout_ms@entry=10, version=version@entry=0) at rdkafka_queue.c:354
#4 0x00007ff2ad21adc8 in rd_kafka_broker_serve (rkb=rkb@entry=0x68c7a10, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3093
#5 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68c7a10, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#6 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68c7a10) at rdkafka_broker.c:4499
#7 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#8 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#9 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 46 (Thread 0x7ff1777fe700 (LWP 6559)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff190000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff190000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68c84a0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68c84a0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68c84a0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 45 (Thread 0x7ff176ffd700 (LWP 6560)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff184000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff184000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68c8f00, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68c8f00, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68c8f00) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 44 (Thread 0x7ff1767fc700 (LWP 6561)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff18c000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff18c000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68c9990, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68c9990, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68c9990) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 43 (Thread 0x7ff175ffb700 (LWP 6562)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff198000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff198000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68ca440, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68ca440, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68ca440) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 42 (Thread 0x7ff1757fa700 (LWP 6563)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff194000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff194000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x68caed0, timeout_ms=timeout_ms@entry=10) at rdkafka_broker.c:3098
#4 0x00007ff2ad21b0f1 in rd_kafka_broker_ua_idle (rkb=rkb@entry=0x68caed0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3143
#5 0x00007ff2ad21b903 in rd_kafka_broker_thread_main (arg=arg@entry=0x68caed0) at rdkafka_broker.c:4499
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 41 (Thread 0x7ff174ff9700 (LWP 6564)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff19c0009c0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff19c0009c0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff224013e80, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21ba34 in rd_kafka_broker_consumer_serve (rkb=0x7ff224013e80) at rdkafka_broker.c:4391
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff224013e80) at rdkafka_broker.c:4503
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 40 (Thread 0x7ff1747f8700 (LWP 6565)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1a00009d0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1a00009d0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff224014920, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21ba34 in rd_kafka_broker_consumer_serve (rkb=0x7ff224014920) at rdkafka_broker.c:4391
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff224014920) at rdkafka_broker.c:4503
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 39 (Thread 0x7ff173ff7700 (LWP 6566)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1ac0009d0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1ac0009d0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff2240153c0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21ba34 in rd_kafka_broker_consumer_serve (rkb=0x7ff2240153c0) at rdkafka_broker.c:4391
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff2240153c0) at rdkafka_broker.c:4503
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 38 (Thread 0x7ff1737f6700 (LWP 6567)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1a80009d0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1a80009d0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff224015e40, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21ba34 in rd_kafka_broker_consumer_serve (rkb=0x7ff224015e40) at rdkafka_broker.c:4391
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff224015e40) at rdkafka_broker.c:4503
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 37 (Thread 0x7ff172ff5700 (LWP 6568)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1b40009d0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1b40009d0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff2240168c0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21ba34 in rd_kafka_broker_consumer_serve (rkb=0x7ff2240168c0) at rdkafka_broker.c:4391
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff2240168c0) at rdkafka_broker.c:4503
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 36 (Thread 0x7ff1727f4700 (LWP 6569)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1b8000a20, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1b8000a20, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1b00010f0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1b00010f0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 35 (Thread 0x7ff171ff3700 (LWP 6570)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1bc000a00, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1bc000a00, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1b0001b50, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1b0001b50) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 34 (Thread 0x7ff1717f2700 (LWP 6571)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1c8000a00, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1c8000a00, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1b00025f0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1b00025f0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 33 (Thread 0x7ff170ff1700 (LWP 6572)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1c4000a00, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1c4000a00, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1b0003050, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1b0003050) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 32 (Thread 0x7ff1707f0700 (LWP 6573)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1d0000dd0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1d0000dd0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1b0003af0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1b0003af0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 31 (Thread 0x7ff16ffef700 (LWP 6574)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1d4000a20, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1d4000a20, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1cc000e10, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1cc000e10) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 30 (Thread 0x7ff16f7ee700 (LWP 6575)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1e0000a00, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1e0000a00, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1cc001820, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1cc001820) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 29 (Thread 0x7ff16efed700 (LWP 6576)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1dc000a00, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1dc000a00, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1cc002290, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1cc002290) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 28 (Thread 0x7ff16e7ec700 (LWP 6577)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1e8000a00, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1e8000a00, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1cc002d30, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1cc002d30) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 27 (Thread 0x7ff16dfeb700 (LWP 6578)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1e4000a80, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1e4000a80, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1cc0037b0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1cc0037b0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 26 (Thread 0x7ff16d7ea700 (LWP 6579)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1f0000a20, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1f0000a20, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1ec001a10, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1ec001a10) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 25 (Thread 0x7ff16cfe9700 (LWP 6580)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1f4000a00, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1f4000a00, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1ec0020e0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1ec0020e0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 24 (Thread 0x7ff16c7e8700 (LWP 6581)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff200000a00, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff200000a00, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1ec002a30, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1ec002a30) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 23 (Thread 0x7ff16bfe7700 (LWP 6582)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff1fc000a80, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff1fc000a80, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1ec003440, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1ec003440) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 22 (Thread 0x7ff16b7e6700 (LWP 6583)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff208000a80, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff208000a80, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff1ec003e50, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff1ec003e50) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 21 (Thread 0x7ff16afe5700 (LWP 6584)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff20c000a20, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff20c000a20, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff204001560, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff204001560) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 20 (Thread 0x7ff16a7e4700 (LWP 6585)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff210000ac0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff210000ac0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff204001c30, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff204001c30) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 19 (Thread 0x7ff169fe3700 (LWP 6586)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff21c000ac0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff21c000ac0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff204002580, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff204002580) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 18 (Thread 0x7ff1697e2700 (LWP 6587)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff218000ac0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff218000ac0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff204002f90, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff204002f90) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 17 (Thread 0x7ff168fe1700 (LWP 6588)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff224000a70, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff224000a70, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff2040039a0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff2040039a0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 16 (Thread 0x7ff1687e0700 (LWP 6589)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff228000b90, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff228000b90, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff220000de0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff220000de0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 15 (Thread 0x7ff167fdf700 (LWP 6590)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff234000ac0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff234000ac0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff2200017f0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff2200017f0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 14 (Thread 0x7ff1677de700 (LWP 6591)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff240000ac0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff240000ac0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff220002230, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff220002230) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 13 (Thread 0x7ff166fdd700 (LWP 6592)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff23c000ac0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff23c000ac0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff220002cb0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff220002cb0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 12 (Thread 0x7ff1667dc700 (LWP 6593)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff248000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff248000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff220003730, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff220003730) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 11 (Thread 0x7ff165fdb700 (LWP 6594)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff250000ac0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff250000ac0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff244000df0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff244000df0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 10 (Thread 0x7ff1657da700 (LWP 6595)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff24c000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff24c000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff244001800, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff244001800) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 9 (Thread 0x7ff164fd9700 (LWP 6596)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff258000b30, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff258000b30, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff244002240, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff244002240) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 8 (Thread 0x7ff1647d8700 (LWP 6597)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff254000b50, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff254000b50, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff244002cc0, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff244002cc0) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 7 (Thread 0x7ff163fd7700 (LWP 6598)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff25c000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff25c000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff244003740, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff244003740) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 6 (Thread 0x7ff1637d6700 (LWP 6599)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff264000ad0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff264000ad0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff268000e20, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff268000e20) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 5 (Thread 0x7ff162fd5700 (LWP 6600)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff270000ac0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff270000ac0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff268001830, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff268001830) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 4 (Thread 0x7ff1627d4700 (LWP 6601)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff26c000ac0, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff26c000ac0, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff268002290, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff268002290) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 3 (Thread 0x7ff161fd3700 (LWP 6602)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff278000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff278000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff268002d10, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff268002d10) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 2 (Thread 0x7ff1617d2700 (LWP 6603)):
#0 0x00007ff2a917069d in poll () from /lib64/libc.so.6
#1 0x00007ff2ad2281da in rd_kafka_transport_poll (rktrans=rktrans@entry=0x7ff274000b40, tmout=tmout@entry=1000) at rdkafka_transport.c:1229
#2 0x00007ff2ad22824b in rd_kafka_transport_io_serve (rktrans=0x7ff274000b40, timeout_ms=1000) at rdkafka_transport.c:1088
#3 0x00007ff2ad21adde in rd_kafka_broker_serve (rkb=rkb@entry=0x7ff268003790, timeout_ms=timeout_ms@entry=0) at rdkafka_broker.c:3098
#4 0x00007ff2ad21d07a in rd_kafka_broker_producer_serve (rkb=) at rdkafka_broker.c:3269
#5 rd_kafka_broker_thread_main (arg=arg@entry=0x7ff268003790) at rdkafka_broker.c:4501
#6 0x00007ff2ad24e087 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#7 0x00007ff2aa07adc5 in start_thread () from /lib64/libpthread.so.0
#8 0x00007ff2a917aced in clone () from /lib64/libc.so.6
Thread 1 (Thread 0x7ff2addf6880 (LWP 6478)):
#0 0x00007ffd2e9327c2 in clock_gettime ()
#1 0x00007ff2a918e93d in clock_gettime () from /lib64/libc.so.6
#2 0x00007ff2ad208323 in rd_clock () at rdtime.h:79
#3 rd_timeout_remains (abs_timeout=3713320035974) at rdtime.h:148
#4 rd_timeout_remains_limit (limit_ms=100, abs_timeout=3713320035974) at rdtime.h:160
#5 rd_kafka_flush (rk=0x68a8050, timeout_ms=) at rdkafka.c:2660
#6 0x0000000000a081f3 in KafkaProducer::flush (this=0xf6c460 <g_rateApp+93536>, timeout_ms=1000) at kafka.cpp:515
#7 0x00000000007adee3 in Output::output (this=0xf69c18 <g_rateApp+83224>) at Outputer.cpp:106
#8 0x00000000007afe98 in Outputer::commitCdr (this=0xf69c00 <g_rateApp+83200>) at Outputer.cpp:557
#9 0x0000000000436563 in RateApp::commit (this=0xf55700 <g_rateApp>) at RateApp.cpp:696
#10 0x00000000004361dd in RateApp::RateRun (this=0xf55700 <g_rateApp>) at RateApp.cpp:634
#11 0x00000000004352fa in RateApp::loopProcess (this=0xf55700 <g_rateApp>) at RateApp.cpp:319
#12 0x000000000044fa1c in Application::mainLoop() ()
#13 0x000000000044fcb7 in Application::run() ()
#14 0x000000000044fcea in main ()
@edenhill
Copy link
Contributor

This is fixed on master: 6745465

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@edenhill @greatt1n