[ https://issues.apache.org/jira/browse/KAFKA-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jay Kreps resolved KAFKA-1343. ------------------------------ Resolution: Cannot Reproduce > 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.3.4#6332)