[jira] [Created] (KAFKA-13481) poll(Duration) hung forever need restart

["jimmy huang (Jira)" <ji...@apache.org>]

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)