jimmy huang created KAFKA-13481:
-----------------------------------
Summary: poll(Duration) hung forever need restart
Key: KAFKA-13481
URL: https://issues.apache.org/jira/browse/KAFKA-13481
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 2.3.0
Reporter: jimmy huang
my kafka broker version is 1.1.0;
topic partition number is 128. then i create 128 Thread for per consumer in one
application;
my consuemrs always run well,but sometimes there is a consumer hung in
poll.only this consumer stuck , others run well.
i dump the Thread info :
java.lang.Thread.State: RUNNABLE
at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
- locked <0x00000004461055c8> (a sun.nio.ch.Util$3)
- locked <0x00000004461055b8> (a java.util.Collections$UnmodifiableSet)
- locked <0x0000000449932670> (a sun.nio.ch.EPollSelectorImpl)
at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
at org.apache.kafka.common.network.Selector.select(Selector.java:794)
at org.apache.kafka.common.network.Selector.poll(Selector.java:467)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:539)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
at
org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1281)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1225)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1201)
no error log ,no rebalance situation。
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
