kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Damian Guy (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (KAFKA-5313) Improve exception handling on coordinator interactions
Date Mon, 19 Feb 2018 11:39:00 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-5313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

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

View raw message