We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9eca0de commit aeb6c7dCopy full SHA for aeb6c7d
core/src/main/scala/kafka/server/ControllerServer.scala
@@ -292,6 +292,7 @@ class ControllerServer(
292
setStreamClient(streamClient).
293
setExtension(c => quorumControllerExtension(c)).
294
setQuorumVoters(config.quorumVoters).
295
+ setReplicaPlacer(replicaPlacer()).
296
// AutoMQ inject end
297
setUncleanLeaderElectionCheckIntervalMs(config.uncleanLeaderElectionCheckIntervalMs).
298
setInterBrokerListenerName(config.interBrokerListenerName.value()).
0 commit comments