apache-kafka - 调查 Kafka-stream 为何处于 ERROR 状态的方法

Question

我将 Spring Cloud Finchley.RELEASE 与 RocksDb 和 Kafka-Streams 一起用于生产应用程序。有时 Kafka-Streams 会进入 ERROR 状态，并且无法访问 store，除了重新启动整个应用程序并删除所有 Kafka-Streams （不要问为什么，它之前实现过）。

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

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

在任何评论中欣赏。

标签： apache-kafkaapache-kafka-streamsspring-cloud-streamspring-kafka

Answer 1

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