System.ObjectDisposeException：句柄被破坏

Question

当我们启动停止消费者服务的进程时，Kafka消费者应用程序抛出ObjectDisposeException。我想了解什么进程破坏了kafka句柄

System.ObjectDisposedException: handle is destroyed
at Confluent.Kafka.Impl.SafeKafkaHandle.ThrowIfHandleClosed()
at Confluent.Kafka.Consumer`2.Consume(Int32 millisecondsTimeout)
at Confluent.Kafka.Consumer`2.Consume(CancellationToken cancellationToken)

Answer 1

就我而言，这个异常是在 .Net Library Confluence Kafka 中引发的。如果您也在使用此库，请确保在 Consumer.Dispose() 之前调用 Consumer.Close()。