I realize the Exponential Backoff Retry Manager exists for the KafkaSpout, but I’m wondering if anyone has implemented similar functionality in a Bolt?
I need to do this to ensure an ElasticSearch cluster isn’t overwhelmed with requests when reading from Kafka. Rick Magnuson | Lead Data Engineer | •Target | 1000 Nicollet Mall | Minneapolis, MN 55403
