[KAFKA-9141] Global state update error: missing recovery or wrong log message

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 2.3.0
• Component/s: streams
• Assignee: Unassigned
• Reporter: Chris Toomey
• Created: 05/Nov/19 06:13
• Updated: 24/Nov/19 23:31

Description

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.
 
I see there's a cleanUp() method on KafkaStreams that looks like it's what's needed, but it's not called anywhere in the streams source code. So either that's a bug and the call should be added to do the recovery, or the log message is wrong and should be fixed.