When calling Consume() [ref], no error handler is provided, so there's no way to know when a terminal error happens. When a terminal error happens (e.g. consumer deletion), the associated member stops processing messages, but still participates as a member, and there's no way out but to kill/restart the process.
When calling
Consume()[ref], no error handler is provided, so there's no way to know when a terminal error happens. When a terminal error happens (e.g. consumer deletion), the associated member stops processing messages, but still participates as a member, and there's no way out but to kill/restart the process.