[STORM-2403] Fix KafkaBolt test failure: tick tuple should not be acked

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 2.0.0, 1.1.0, 1.0.4
• Fix Version/s: 2.0.0, 1.1.0, 1.0.4
• Component/s: storm-kafka
• Epic Link: Release Apache Storm 1.1.0
• Assignee: Jungtaek Lim
• Reporter: Jungtaek Lim
• Created: 09/Mar/17 16:12
• Updated: 13/Mar/17 08:15
• Resolved: 13/Mar/17 08:15

Description

From STORM-2387, I changed KafkaBolt to make sure it doesn't ack tick tuples.
(Tick tuples are generated from each executor and don't trigger ACK_INIT so actually it should not be acked. Acker will keep them and remove some for message timeout so not a big deal though.)

But I forgot to fix unit test for that, and also missed to check test result. This issue is for making quick fix for that.

Issue Links

• links to: GitHub Pull Request #1994