[
https://issues.apache.org/jira/browse/KAFKA-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969047#comment-16969047
]
Matthias J. Sax commented on KAFKA-9141:
----------------------------------------
Calling `cleanUp()` is something a user would need to to explicitly – there is
no reason for Kafka Streams to call it.
Can you share the full StackTrace/Error message?
> Global state update error: missing recovery or wrong log message
> ----------------------------------------------------------------
>
> Key: KAFKA-9141
> URL: https://issues.apache.org/jira/browse/KAFKA-9141
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 2.3.0
> Reporter: Chris Toomey
> Priority: Major
>
> 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
