BookkeeperClientFactory should pass in the ZK instance (#12192)

apache · Sep 26, 2021 · 33580ca · 33580ca
1 parent f822016
commit 33580ca
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java
@@ -81,6 +81,7 @@ public BookKeeper create(ServiceConfiguration conf, ZooKeeper zkClient, EventLoo
         try {
             return BookKeeper.forConfig(bkConf)
                     .allocator(PulsarByteBufAllocator.DEFAULT)
+                    .setZookeeper(zkClient)
                     .eventLoopGroup(eventLoopGroup)
                     .statsLogger(statsLogger)
                     .build();