[KAFKA-241] ConsumerIterator throws a IllegalStateException after a ConsumerTimeout occurs

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.7
• Fix Version/s: 0.7.1
• Labels: newbie
• Assignee: Jun Rao
• Reporter: Patricio Echague
• Created: 06/Jan/12 00:55
• Updated: 19/Jun/14 05:16
• Resolved: 19/Jan/12 17:54

Description

Please find the test case attached.

After a timeout occurs (property consumer.timeout.ms > 0 ) the consumerIterator throws an IllegalStateException.

The work around seems to be to recreate the MessageStream an issue a new Iterator.