From 02784174943e2327a00e785534c2e820fc4c8d03 Mon Sep 17 00:00:00 2001 From: Liquan Pei Date: Wed, 20 Apr 2016 12:00:32 -0700 Subject: [PATCH] Minor comment fix --- .../kafka/connect/runtime/distributed/DistributedHerder.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java index 24d548d112a34..7b5f891d51b0a 100644 --- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java +++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java @@ -846,8 +846,8 @@ private void reconfigureConnector(final String connName, final Callback cb configStorage.putTaskConfigs(taskConfigListAsMap(connName, taskProps)); cb.onCompletion(null, null); } else { - // We cannot forward the request on the same thread because this reconfiguration can happen in as a - // result of . If we blocked + // We cannot forward the request on the same thread because this reconfiguration can happen as a result of connector + // addition or removal. If we blocked waiting for the response from leader, we may be kicked out of the worker group. forwardRequestExecutor.submit(new Runnable() { @Override public void run() {