@Override
    public Integer rebalanceTimeout() {
        return getInt(DistributedConfig.REBALANCE_TIMEOUT_MS_CONFIG);
    }
<code>scheduled.rebalance.max.delay.ms</code>
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java