Hello,

I encounter this issue when using the storm 1.1 KafkaSpout. I configure the
retryService like this:

spoutConfigBuilder.setRetry(new
KafkaSpoutRetryExponentialBackoff(KafkaSpoutRetryExponentialBackoff.TimeInterval.seconds(0),
KafkaSpoutRetryExponentialBackoff.TimeInterval.milliSeconds(2),
                5,
KafkaSpoutRetryExponentialBackoff.TimeInterval.seconds(10)));
spoutConfigBuilder.build()

But, I see that it still retry indefinitely the failed tuples... Any info
or know issue on this feature ?

Thanks

Reply via email to