Describe the bug
We are seeing ObjectDisposedException in the Kafka listener when our pods shutdown/rebalance. Any in-flight messages are not waited on which appears to be causing the exception.
To Reproduce
Ensure in-flight messages are being processed, then kill the host.
Expected behavior
The consume loop is cancelled, the current message is processed and then the host shuts down cleanly.
Describe the bug
We are seeing ObjectDisposedException in the Kafka listener when our pods shutdown/rebalance. Any in-flight messages are not waited on which appears to be causing the exception.
To Reproduce
Ensure in-flight messages are being processed, then kill the host.
Expected behavior
The consume loop is cancelled, the current message is processed and then the host shuts down cleanly.