[STORM-2357] add At-Most-Once guarantee in KafkaSpout

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.0.0, 1.2.0
• Component/s: storm-kafka-client
• Assignee: Stig Rohde Døssing
• Reporter: Mingmin Xu
• Created: 14/Feb/17 00:00
• Updated: 02/Oct/17 16:10
• Resolved: 02/Oct/17 16:10

Description

KafkaSpout cannot guarantee exactly at-most-once semantic, as it commits offset periodically, and KafkaSpout.close() is not guarantee to call when a crash happens.

Issue Links

• is related to: STORM-2648 Kafka spout can't show acks/fails and complete latency when auto commit is enabled