[ https://issues.apache.org/jira/browse/CRUNCH-662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Bryan Baugher updated CRUNCH-662: --------------------------------- Attachment: 0001-CRUNCH-662-Updated-KafkaRecordReader-to-better-handl.patch > Improve KafkaSource error handling > ---------------------------------- > > Key: CRUNCH-662 > URL: https://issues.apache.org/jira/browse/CRUNCH-662 > Project: Crunch > Issue Type: Improvement > Reporter: Bryan Baugher > Priority: Major > Attachments: > 0001-CRUNCH-662-Updated-KafkaRecordReader-to-better-handl.patch > > > The KafkaSource and specific KafkaRecordReader does not handle errors and > empty reads as well as it could. The code could be improved to better handle > these errors and appropriately retry -- This message was sent by Atlassian JIRA (v7.6.3#76005)