[ https://issues.apache.org/jira/browse/CRUNCH-662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Josh Wills resolved CRUNCH-662. ------------------------------- Resolution: Fixed Fix Version/s: 1.0.0 LGTM and merged to master-- thanks Bryan! > 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 > Fix For: 1.0.0 > > 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)