"asyncmq-44-topic ***_topic | group ***_group-pull-1" #826 daemon prio=5 os_prio=0 cpu=4738879.51ms elapsed=14690.27s tid=0x00007f962e926410 nid=0x7746 runnable  [0x00007f95a625a000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPoll.wait(java.base@17.0.3/Native Method)
	at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@17.0.3/EPollSelectorImpl.java:118)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@17.0.3/SelectorImpl.java:129)
	- locked <0x0000000637bbea90> (a sun.nio.ch.Util$2)
	- locked <0x0000000637bbea40> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.selectNow(java.base@17.0.3/SelectorImpl.java:151)
	at org.apache.kafka.common.network.Selector.select(Selector.java:792)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:467)
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:535)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)
	at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1256)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1200)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1176)
	at us.zoom.mq.client.impl.kafka.ConsumerClient.poll(ConsumerClient.java:192)
	at us.zoom.mq.client.worker.PullWorker.run(PullWorker.java:149)
	at us.zoom.commons.threadpool.ZoomRunnable.run(ZoomRunnable.java:55)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@17.0.3/ThreadPoolExecutor.java:1136)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@17.0.3/ThreadPoolExecutor.java:635)
	at java.lang.Thread.run(java.base@17.0.3/Thread.java:833)
	at us.zoom.commons.threadpool.ZoomRunnable.run(ZoomRunnable.java:55)
	at java.lang.Thread.run(java.base@17.0.3/Thread.java:833)

   Locked ownable synchronizers:
	- <0x0000000637bd3558> (a java.util.concurrent.locks.ReentrantLock$FairSync)
	- <0x0000000637bd7918> (a java.util.concurrent.ThreadPoolExecutor$Worker)
	
	
	
	
	
	
"asyncmq-78-topic ***_topic | group ***_group-pull-1" #1042 daemon prio=5 os_prio=0 cpu=4739669.91ms elapsed=14674.35s tid=0x00007f962e9be610 nid=0x77fb runnable  [0x00007f959c6d6000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPoll.wait(java.base@17.0.3/Native Method)
	at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@17.0.3/EPollSelectorImpl.java:118)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@17.0.3/SelectorImpl.java:129)
	- locked <0x000000062a1e4930> (a sun.nio.ch.Util$2)
	- locked <0x000000062a1e48e0> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.selectNow(java.base@17.0.3/SelectorImpl.java:151)
	at org.apache.kafka.common.network.Selector.select(Selector.java:792)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:467)
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:535)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)
	at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1256)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1200)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1176)
	at us.zoom.mq.client.impl.kafka.ConsumerClient.poll(ConsumerClient.java:192)
	at us.zoom.mq.client.worker.PullWorker.run(PullWorker.java:149)
	at us.zoom.commons.threadpool.ZoomRunnable.run(ZoomRunnable.java:55)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@17.0.3/ThreadPoolExecutor.java:1136)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@17.0.3/ThreadPoolExecutor.java:635)
	at java.lang.Thread.run(java.base@17.0.3/Thread.java:833)
	at us.zoom.commons.threadpool.ZoomRunnable.run(ZoomRunnable.java:55)
	at java.lang.Thread.run(java.base@17.0.3/Thread.java:833)

   Locked ownable synchronizers:
	- <0x000000062a1e4b80> (a java.util.concurrent.ThreadPoolExecutor$Worker)
	- <0x000000062d897ed0> (a java.util.concurrent.locks.ReentrantLock$FairSync)