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
