[STORM-693] KafkaBolt exception handling improvement

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.3
• Fix Version/s: 0.10.0, 0.9.4
• Component/s: storm-kafka
• Assignee: Parth Brahmbhatt
• Reporter: Richard Kellog Jr.
• Created: 26/Feb/15 21:48
• Updated: 19/May/15 01:41
• Resolved: 18/Mar/15 15:01

Description

Within the KafkaBolt execute method, an error message is logged if any sort of error occurs communicating with Kafka. Unfortunately the input is still acknowledged.

Upon review of the HdfsBolt & HiveBolt, I believe the exception handling block should include the following two lines:

this.collector.reportError(ex);
this.collector.fail(input);