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:
- Kafka-Streams troubleshooting;
- How to get which bad messages broken the internal streams;
- How to validate and handle such errors;
- How to do logging when Kafka Streams is broken in run-time;
Appreciate in any comments.