[
https://issues.apache.org/jira/browse/KAFKA-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16972164#comment-16972164
]
Chris Toomey commented on KAFKA-9141:
-------------------------------------
Yes that'd be a more helpful error message.
As far as the embedding application detecting this situation, it seems that's
provided by the {{setUncaughtExceptionHandler()}} method, which would be called
in this case, right? So the app could shutdown instead of continuing to run
with a broken/stopped streams app.
> 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)
