[
https://issues.apache.org/jira/browse/KAFKA-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shashank resolved KAFKA-19864.
------------------------------
Reviewer: Lucas Brutschy
Resolution: Resolved
> Handle TimeoutException from initializeIfNeeded() in StateUpdater Code
> ----------------------------------------------------------------------
>
> Key: KAFKA-19864
> URL: https://issues.apache.org/jira/browse/KAFKA-19864
> Project: Kafka
> Issue Type: Task
> Components: streams
> Reporter: Shashank
> Assignee: Shashank
> Priority: Blocker
> Fix For: 4.2.0
>
>
> Identified [here|https://github.com/apache/kafka/pull/20818/files#r2490887612]
> When using the StateUpdater mode, tasks that throw TimeoutException during
> initializeIfNeeded() are not handled, making it inconsistent compared to the
> non-StateUpdater mode.
> [Link to
> Code|https://github.com/apache/kafka/blob/55764f837b744dcaf2295f4af5170bf25c2f48e9/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java#L1080]
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
