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