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)
