Damian Guy updated KAFKA-5313:
    Fix Version/s:     (was: 1.1.0)

> 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:
>            Reporter: Eno Thereska
>            Assignee: Matthias J. Sax
>            Priority: Major
> 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

Reply via email to