[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989974#comment-16989974 ]
Boyang Chen commented on KAFKA-9274: ------------------------------------ Thanks for the summary John. I think what we particularly need is case #1, which is the graceful handling of timeout. For initPid request specifically, seems we need to do an infinite while-loop to iterate through all tasks until all of them are initialized. > Gracefully handle timeout exceptions on Kafka Streams > ----------------------------------------------------- > > Key: KAFKA-9274 > URL: https://issues.apache.org/jira/browse/KAFKA-9274 > Project: Kafka > Issue Type: Improvement > Components: streams > Reporter: Boyang Chen > Priority: Major > > Right now streams don't treat timeout exception as retriable in general by > throwing it to the application level. If not handled by the user, this would > kill the stream thread unfortunately. > In fact, timeouts happen mostly due to network issue or server side > unavailability. Hard failure on client seems to be an over-kill. > We would like to discuss what's the best practice to handle timeout > exceptions on Streams. The current state is still brainstorming and > consolidate all the cases that contain timeout exception within this ticket. -- This message was sent by Atlassian Jira (v8.3.4#803005)