Rick Kellogg created STORM-693:
----------------------------------
Summary: KafkaBolt exception handling improvement
Key: STORM-693
URL: https://issues.apache.org/jira/browse/STORM-693
Project: Apache Storm
Issue Type: Bug
Reporter: Rick Kellogg
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);
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
