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,