schandr created KAFKA-1343:
------------------------------
Summary: Kafka consumer iterator thread stalls
Key: KAFKA-1343
URL: https://issues.apache.org/jira/browse/KAFKA-1343
Project: Kafka
Issue Type: Bug
Reporter: schandr
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)
