[
https://issues.apache.org/jira/browse/STORM-822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15174299#comment-15174299
]
ASF GitHub Bot commented on STORM-822:
--------------------------------------
Github user hmcl commented on the pull request:
https://github.com/apache/storm/pull/1131#issuecomment-190870605
@jianbzhou if tuples 1-5 have been emitted, if 3 fails, currently only 2 is
re-emitted. Offsets 1,2 are committed, and the offsets 3-5 are only committed
once 2 is acked.
I think that It should not be too hard to send again tuples 3-5, the
problem is that the downstream component would receive once the tuples 4 and 5
twice. We try avoiding duplicates a much as possible, although in some failure
scenarios it can still occur.
The problem that you are describing isn't well solved by trident? Isn't it
one of the purposes it was built for?
> As a storm developer I’d like to use the new kafka consumer API (0.8.3) to
> reduce dependencies and use long term supported kafka apis
> --------------------------------------------------------------------------------------------------------------------------------------
>
> Key: STORM-822
> URL: https://issues.apache.org/jira/browse/STORM-822
> Project: Apache Storm
> Issue Type: Story
> Components: storm-kafka
> Reporter: Thomas Becker
> Assignee: Hugo Louro
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
