Способы выяснить, почему Kafka-stream находится в состоянии ERROR

Question

Я использую Spring Cloud Finchley.RELEASE с RocksDb и Kafka-Streams для производственного приложения.Иногда Kafka-Streams переходят в состояние ERROR, и нет доступа к хранилищу, кроме перезапуска всего приложения с удалением всех Kafka-Streams (не спрашивайте, почему, это было реализовано ранее).

Есть ли у вас рекомендации по следующим вопросам:

1. Устранение неполадок Kafka-Streams;
2. Как узнать, какие плохие сообщения прервали внутренние потоки;
3. Как проверять и обрабатывать такие ошибки;
4. Как вести журнал, когда Kafka Streams не работает во время выполнения;

Оценить в любых комментариях.

Answer 1

Вы можете использовать DLQ для обработки недопустимого сообщения.