BookkeeperClientFactory should pass in the ZK instance
@@ -81,6 +81,7 @@ public class BookKeeperClientFactoryImpl implements BookKeeperClientFactory {
try {
return BookKeeper.forConfig(bkConf)
.allocator(PulsarByteBufAllocator.DEFAULT)
+ .setZookeeper(zkClient)
.eventLoopGroup(eventLoopGroup)
.statsLogger(statsLogger)
.build();
