Folks, My user case is a bit different: I need to read from a specific kafka topic at specific time. Thus I have a signal spout signaling the downstream bolt to start read from the topic.(and stop reading if timeout) So apparently I will have multiple bolt threads read from the same kafka topic.
I am currently using the High Level API(consumer group) to read from kafka. i am most concerned about error recovery. If one processing bolt dies, will other running bolt threads picks up the failed message? Or I have to start another thread in order to pick up the failed message? What would be a good practice to ensure the message can be processed at least once, without depending on the kakfa spout? Note that all threads are using the same group id. Thanks, Chen
