Ewen Cheslack-Postava created KAFKA-2713:
--------------------------------------------
Summary: Copycat worker should not call connector's/task's start
methods in the control thread
Key: KAFKA-2713
URL: https://issues.apache.org/jira/browse/KAFKA-2713
Project: Kafka
Issue Type: Sub-task
Reporter: Ewen Cheslack-Postava
Assignee: Ewen Cheslack-Postava
Currently the DistributedHerder calls start() methods in the same thread as the
group membership is handled. This is simple and makes lifecycles easier to
reason about, but also means that user code (and even code that can simply
block for a long time, like sink task's connectors) can potentially block group
membership, which in turn causes the worker to fall out of the group.
To avoid this, we should run these methods in the worker thread for each
connector/task.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
