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 index 996bf225892af..9a09deb166b0f 100644 --- 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,7 +81,6 @@ public BookKeeper create(ServiceConfiguration conf, ZooKeeper zkClient, EventLoo try { return BookKeeper.forConfig(bkConf) .allocator(PulsarByteBufAllocator.DEFAULT) - .setZookeeper(zkClient) .eventLoopGroup(eventLoopGroup) .statsLogger(statsLogger) .build();