[ https://issues.apache.org/jira/browse/KAFKA-7145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539982#comment-16539982 ]
Andras Beni commented on KAFKA-7145: ------------------------------------ [~lovenishgoyal], as I can see you are using the so called 'old client' (the one residing in artifact org.apache.kafka:kafka_<scalaversion>). It has been deprecated for quite some time and has not got bugfixes lately. It will even be removed in version 2.0.0 (ETA: in a few days). So I would not expect the community to put much effort in debugging and fixing bugs in this client. I recommend to migrate to the 'new client' (org.apache.kafka.clients.consumer.KafkaConsumer in artifact org.apache.kafka:kafka-clients) and try to reproduce the issue with that. Probably this behavior has been fixed already. > Consumer thread getting stuck in hasNext() method > ------------------------------------------------- > > Key: KAFKA-7145 > URL: https://issues.apache.org/jira/browse/KAFKA-7145 > Project: Kafka > Issue Type: Bug > Components: clients > Affects Versions: 0.9.0.1, 0.10.0.1 > Reporter: Lovenish goyal > Priority: Blocker > > Consumer thread is getting stuck at *hasNext()* method. > we are using ConsumerIterator for same and below is the code snipped > > {code:java} > ConsumerIterator mIterator; > List<KafkaStream<byte[], byte[]>> streams = > mConsumerConnector.createMessageStreamsByFilter(topicFilter); > KafkaStream<byte[], byte[]> stream = streams.get(0); > mIterator = stream.iterator(); > {code} > > When i manually check via [Kafdrop|https://github.com/HomeAdvisor/Kafdrop] I > am seeing 'No message found' message.I have tried same with both kafka > version 9 & 10 and getting same issue. > -- This message was sent by Atlassian JIRA (v7.6.3#76005)