[
https://issues.apache.org/jira/browse/KAFKA-5313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-5313:
---------------------------------
*Reminder to the contributor / reviewer of the PR*: please note that the code
deadline for 1.0.0 is less than 2 weeks away (Oct. 4th). Please re-evaluate
your JIRA and see if it still makes sense to be merged into 1.0.0 or it could
be pushed out to 1.1.0, or be closed directly if the JIRA itself is not valid
any more, or re-assign yourself as contributor / committer if you are no longer
working on the JIRA.
> Improve exception handling on coordinator interactions
> ------------------------------------------------------
>
> Key: KAFKA-5313
> URL: https://issues.apache.org/jira/browse/KAFKA-5313
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Affects Versions: 0.11.0.0
> Reporter: Eno Thereska
> Assignee: Matthias J. Sax
> Fix For: 1.0.0
>
>
> Exceptions during assignment of tasks are caught in ConsumerCoordinator.java
> and streams becomes aware of them during the
> StreamThread.onPartitionsAssigned() and StreamThread.onPartitionsRevoked()
> methods. Eventually these exceptions go through StreamThread.pollRequests()
> all the way up to StreamThread.runLoop() and will halt the stream thread that
> is processing these exceptions. Other stream threads may continue processing,
> however it is likely they will experience problems too soon after.
> Exceptions here include LockExceptions that are thrown if tasks cannot use a
> particular directory due to previous tasks not releasing locks on them during
> reassignment.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
