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

Reply via email to