[ 
https://issues.apache.org/jira/browse/KAFKA-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16178421#comment-16178421
 ] 

Matthias J. Sax commented on KAFKA-5217:
----------------------------------------

I am not sure if we should ignore **all** exceptions during rebalance. Assume, 
get {{TimeoutException}} we might eventually just give up. Two issues with 
unstable rebalance are tackled via KAFKA-4593 and KAFKA-5541. I would close 
this as duplicate for now as I think the two mentioned JIRAs cover what we 
need. \cc [~guozhang] [~damianguy] [~bbejeck] WDYT? Is there any other case we 
should consider to make rebalance more resilient?

> Improve Streams internal exception handling
> -------------------------------------------
>
>                 Key: KAFKA-5217
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5217
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: streams
>    Affects Versions: 0.10.2.1
>            Reporter: Matthias J. Sax
>            Assignee: Matthias J. Sax
>             Fix For: 1.0.0
>
>
> Streams does not handle all exceptions gracefully atm, but tend to throw 
> exceptions to the user, even if we could handle them internally and recover 
> automatically. We want to revisit this exception handling to be more 
> resilient.
> For example, for any kind of rebalance exception, we should just log it, and 
> rejoin the consumer group.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to