[STORM-2413] New Kafka spout is ignoring retry limit

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 2.0.0, 1.1.1, 1.2.0
• Component/s: storm-kafka-client
• Epic Link: Release Apache Storm 1.1.0
• Assignee: Stig Rohde Døssing
• Reporter: Stig Rohde Døssing
• Created: 14/Mar/17 21:11
• Updated: 26/Aug/17 20:52
• Resolved: 21/May/17 11:45

Description

The new Kafka spout ignores retry limits. The problem is that a new KafkaSpoutMessageId is constructed on every retry, so the numFails counter it contains is always either 0 or 1. We should reuse the existing message id when retrying a record.

Issue Links

• is duplicated by: STORM-2352 New Kafka spout retries for ever even with retries of 5
• links to: GitHub Pull Request #2004