我注意到，周期性地，流处理器将转换到 ERROR 的状态，并且该过程将在不退出的情况下坐在那里 .
显示我的日志：
All stream threads have died. The instance will be in error state and should be closed.
有没有办法告诉Streams应用程序一旦达到 ERROR 状态就退出？也许是各种监视器线程？
我在Kafka Streams代码的注释中看到references对于需要在应用程序达到此状态时关闭应用程序的用户，但是，我无法在文档中找到提及此任务的内容 .
有没有一种简单的方法来执行此关闭步骤？
可能是错误的方法，可能会关闭错误
我的目的是在 KafkaStreams 对象上设置 UncaughtExceptionHandler 方法，以执行以下操作：
-
记录错误
-
使用原始
KafkaStreams对象上的close方法关闭流
结果是：
记录异常的
-
消息
-
INFO org.apache.kafka.streams.KafkaStreams ... State transition from ERROR to PENDING_SHUTDOWN -
INFO org.apache.kafka.streams.processor.internals.StreamThread ... Informed to shut down
然后，不幸的是，这个过程似乎没有退出 .
FWIW我觉得这可能是误用 setUncaughtExceptionHandler
1 回答
使用
UncaughtExceptionHandler是正确的 . 但是，如果在处理程序回调中调用KafkaStreams#close()，则可能会遇到死锁 . 因此，您应该只设置一个标志，并在回调之外调用#close()，或者使用close()超时 . 如果超时到期，则强制关闭 .