[jira] [Created] (KAFKA-5313) Improve exception handling on coordinator interactions

["Eno Thereska (JIRA)" <ji...@apache.org>]

Eno Thereska created KAFKA-5313:
-----------------------------------

             Summary: 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: Eno Thereska


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.3.15#6346)