I'm getting an OffsetOutOfRangeException accompanied by the log message
"Updating global state failed. You can restart KafkaStreams to recover from
this error." But I've restarted the app several times and it's not
recovering, it keeps failing the same way.

Is this error message just wrong (and should be changed), or if not, why
might the restart recovery not be happening?

I see there's a cleanUp() method on KafkaStreams that looks like it's
what's needed, but I don't find any callers of it in the streams source
code.

thx,
Chris

Reply via email to