[jira] [Commented] (KAFKA-7145) Consumer thread getting stuck in hasNext() method

["Andras Beni (JIRA)" <ji...@apache.org>]

    [ 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)