[
https://issues.apache.org/jira/browse/KAFKA-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
schandr updated KAFKA-1343:
---------------------------
Attachment: producerscreenshot.jpg
> Kafka consumer iterator thread stalls
> -------------------------------------
>
> Key: KAFKA-1343
> URL: https://issues.apache.org/jira/browse/KAFKA-1343
> Project: Kafka
> Issue Type: Bug
> Reporter: schandr
> Attachments: producerscreenshot.jpg
>
>
> My dev enviornment has Kafka 0.8.0. I am using High level consumer API. My
> use case has one topic with 2 partitions. My code is using two threads to
> read from the kafka stream. The runnable iterator task has the below
> implementation
> public void run() {
> ConsumerIterator<byte[], byte[]> it = stream.iterator();
> while (it.hasNext()){
> MessageAndMetadata<byte[], byte[]> msgAndmtdata = it.next();
> byte message[] = msgAndmtdata.message();
> long offset = msgAndmtdata.offset();
> MessageAndOffset msgAndOffst = new
> MessageAndOffset(message, offset);
> System.out.println(" Message offset for topic : " +
> topicName + ": " + offset + "thread :" + thread + "Message: " + new
> String(message));
>
> }
> }
> I am using kafka console producer to produce messages. When the test starts,
> the above logs the messages produced so far, but stalls for new messages
> produced by the console producer. No exception in the kafka logs.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
