Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
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.
Attachments
Issue Links
- is related to
-
STORM-2648 Kafka spout can't show acks/fails and complete latency when auto commit is enabled
-
- Resolved
-