[APEXMALHAR-1689] Exception caught from consumer thread in SimpleKafkaConsumer

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.1.0
• Assignee: Chaitanya Chebolu
• Reporter: Chaitanya Chebolu
• Created: 04/Mar/15 09:50
• Updated: 03/Jan/16 10:00
• Resolved: 09/Oct/15 12:39

Description

ERROR com.datatorrent.contrib.kafka.SimpleKafkaConsumer: The consumer encounters an unrecoverable exception. Close the connection to broker id:2,host:node15.morado.com,port:9094
Caused by java.util.ConcurrentModificationException
2015-03-04 01:47:47,669 INFO com.datatorrent.contrib.kafka.SimpleKafkaConsumer: Exit the consumer thread for broker id:2,host:node15.morado.com,port:9094