I'm using Spring Cloud Finchley.RELEASE with RocksDb and Kafka-Streams for production application. Sometimes Kafka-Streams go to ERROR state and there is no way to access to store, except of restarting the whole application with removing all Kafka-Streams (don't ask why, it was implemented before).

Do you have some recommendations about:

  1. Kafka-Streams troubleshooting;
  2. How to get which bad messages broken the internal streams;
  3. How to validate and handle such errors;
  4. How to do logging when Kafka Streams is broken in run-time;

Appreciate in any comments.

1 Answers

0
zhiguo du On

You could use DLQ to handler invalid message.