Andras Beni commented on KAFKA-7145:

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:,
>            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

Reply via email to