From 2af41689b7a7b2c79e6d1f790f1309dbc511d9ca Mon Sep 17 00:00:00 2001 From: Jason Gustafson Date: Mon, 7 Dec 2020 10:22:19 -0800 Subject: [PATCH] MINOR: Configure reconnect backoff in `BrokerToControllerChannelManager` --- .../kafka/server/BrokerToControllerChannelManagerImpl.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/server/BrokerToControllerChannelManagerImpl.scala b/core/src/main/scala/kafka/server/BrokerToControllerChannelManagerImpl.scala index 7e500a0c0883d..1054f897d34db 100644 --- a/core/src/main/scala/kafka/server/BrokerToControllerChannelManagerImpl.scala +++ b/core/src/main/scala/kafka/server/BrokerToControllerChannelManagerImpl.scala @@ -101,8 +101,8 @@ class BrokerToControllerChannelManagerImpl(metadataCache: kafka.server.MetadataC manualMetadataUpdater, config.brokerId.toString, 1, - 0, - 0, + 50, + 50, Selectable.USE_DEFAULT_BUFFER_SIZE, Selectable.USE_DEFAULT_BUFFER_SIZE, config.requestTimeoutMs,