motornet icon indicating copy to clipboard operation
motornet copied to clipboard

Safely close Kafka consumer

Open rngcntr opened this issue 8 months ago • 0 comments

Fixes #1283

Calling both Dispose() and Close() on a consumer will yield an exception that the inner handler has already been disposed. Since there are two possible ways a KafkaMessageConsumer can be stopped, I migrated both of them to call a safe CloseOrDispose() method.

rngcntr avatar Apr 14 '25 07:04 rngcntr