[
https://issues.apache.org/jira/browse/STORM-2014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hugo Louro updated STORM-2014:
------------------------------
Component/s: (was: storm-kafka)
storm-kafka-client
> New Kafka spout duplicates checking if failed messages have reached max
> retries
> -------------------------------------------------------------------------------
>
> Key: STORM-2014
> URL: https://issues.apache.org/jira/browse/STORM-2014
> Project: Apache Storm
> Issue Type: Improvement
> Components: storm-kafka-client
> Reporter: Stig Rohde Døssing
> Assignee: Stig Rohde Døssing
> Priority: Minor
> Fix For: 2.0.0, 1.1.0
>
> Time Spent: 1.5h
> Remaining Estimate: 0h
>
> The new Kafka spout has a RetryService interface that should make logic
> around retrying tuples pluggable. The RetryServiceExponentialBackoff class
> has code for setting a max retry count, and dropping messages once they reach
> the retry limit. This functionality is duplicated by the spout in the fail
> method, which means that the user must set different maxRetries for the
> RetryService and the spout in order for the RetryService code to be hit when
> dropping messages.
> I think the retry logic belongs in the RetryService interface, and should be
> removed from the spout. It would also be good if the RetryService could
> indicate if a message will be retried or not.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
