Thanks Yi. We recovered this time around by processing all of the
checkpoints manually, deleting and recreating the checkpoint topic, then
re-populating the checkpoint topic with the saved offsets using the
checkpoint tool,. If it happens again, I'll turn up logging to try and get
more information.
Hi, Malcolm,
Samza 0.14.1 is pretty old and if you have already upgraded Kafka to 2.2.1,
I would highly recommend you to migrate to latest Samza version, which has
Kafka 2.0 client. Depending on how you configure your broker, a 2.0 Kafka
broker can be incompatible with older client like 0.8.6, sin
