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
