Thanks. i ended up catching any exception in the consumer thread and retrying the iteration unless i specifically toggled it to dump and quit on error.
Sent from my Droid Charge on Verizon 4G LTE Jun Rao wrote: Normally, consumers don't timeout unless you have configured it. You just need to make sure you don't kill the consumer thread if it hits an application error. Thanks, Jun On Mon, Oct 28, 2013 at 5:21 PM, Joseph Lawson <jlaw...@roomkey.com> wrote: > Hi everyone, > > how should a high level consumer implementation handle consumer > exceptions. Using the high level consumer wiki example, the primary thread > calls an example.run() and then waits for a thread.sleep and then shuts > down. If each ConsumerTest is a thread, what is the best way for the > parent thread to handle consumer exceptions such as a consumer timeout or a > rebalance max retries exception? > > I've run into cases where my high level consumer just keeps spinning while > my consumer threads are crashed. Any suggestions as to how I should detect > the exceptions from the consumer threads in the high level consumer logic? > > Thanks! > > -Joe Lawson >
