调查 Kafka 流为何处于 ERROR 状态的方法

Question

我正在使用Spring Cloud Finchley.RELEASE和RocksDb和Kafka-Streams用于生产应用程序。有时 Kafka-Streams 会进入 ERROR 状态，除了通过删除所有 Kafka-Streams 重新启动整个应用程序之外，无法访问存储(不要问为什么，它以前已经实现过(。

您对以下方面有什么建议吗：

1. Kafka-Streams 故障排除;
2. 如何获取哪些不良消息破坏了内部流;
3. 如何验证和处理此类错误;
4. 当 Kafka 流在运行时中断时如何进行日志记录;

感谢任何评论。

Answer 1

您可以使用 DLQ 来处理无效消息。