MINOR: fix typo in KAFKA-16515

apourchet · May 27, 2024 · bac8df5 · bac8df5
1 parent da3304e
commit bac8df5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/kafka/server/KafkaServer.scala b/core/src/main/scala/kafka/server/KafkaServer.scala
@@ -441,7 +441,7 @@ class KafkaServer(
             CompletableFuture.completedFuture(quorumVoters),
             fatalFaultHandler = new LoggingFaultHandler("raftManager", () => shutdown())
           )
-          val quorumControllerNodeProvider = RaftControllerNodeProvider(raftManager, config)
+          quorumControllerNodeProvider = RaftControllerNodeProvider(raftManager, config)
           val brokerToQuorumChannelManager = new NodeToControllerChannelManagerImpl(
             controllerNodeProvider = quorumControllerNodeProvider,
             time = time,