From d7f8ec8628ee18326d22f6a58c787629a8faf307 Mon Sep 17 00:00:00 2001 From: Konstantine Karantasis Date: Sun, 25 Aug 2019 15:35:03 -0700 Subject: [PATCH] MINOR: Fix the doc of scheduled.rebalance.max.delay.ms config property (#7242) Author: Konstantine Karantasis Reviewer: Randall Hauch --- .../kafka/connect/runtime/distributed/DistributedConfig.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java index bc3bc19cce7..0d66c35f681 100644 --- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java +++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java @@ -144,7 +144,10 @@ public class DistributedConfig extends WorkerConfig { * connect.protocol */ public static final String SCHEDULED_REBALANCE_MAX_DELAY_MS_CONFIG = "scheduled.rebalance.max.delay.ms"; - public static final String SCHEDULED_REBALANCE_MAX_DELAY_MS_DOC = "Compatibility mode for Kafka Connect Protocol"; + public static final String SCHEDULED_REBALANCE_MAX_DELAY_MS_DOC = "The maximum delay that is " + + "scheduled in order to wait for the return of one or more departed workers before " + + "rebalancing and reassigning their connectors and tasks to the group. During this " + + "period the connectors and tasks of the departed workers remain unassigned"; public static final int SCHEDULED_REBALANCE_MAX_DELAY_MS_DEFAULT = Math.toIntExact(TimeUnit.SECONDS.toMillis(300)); static {