[ https://issues.apache.org/jira/browse/STORM-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stig Rohde Døssing resolved STORM-2357. --------------------------------------- Resolution: Fixed Fix Version/s: 1.2.0 > add At-Most-Once guarantee in KafkaSpout > ---------------------------------------- > > Key: STORM-2357 > URL: https://issues.apache.org/jira/browse/STORM-2357 > Project: Apache Storm > Issue Type: Bug > Components: storm-kafka-client > Reporter: Xu Mingmin > Assignee: Stig Rohde Døssing > Fix For: 2.0.0, 1.2.0 > > > 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. -- This message was sent by Atlassian JIRA (v6.4.14#64029)