[jira] [Resolved] (KAFKA-1343) Kafka consumer iterator thread stalls

["Jay Kreps (JIRA)" <ji...@apache.org>]

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