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 67a12a7f402f8..a59ee6525235a 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 @@ -123,7 +123,6 @@ ClientConfiguration createBkClientConfiguration(ServiceConfiguration conf) { bkConf.setStickyReadsEnabled(conf.isBookkeeperEnableStickyReads()); bkConf.setNettyMaxFrameSizeBytes(conf.getMaxMessageSize() + Commands.MESSAGE_SIZE_FRAME_PADDING); bkConf.setDiskWeightBasedPlacementEnabled(conf.isBookkeeperDiskWeightBasedPlacementEnabled()); - bkConf.setNumWorkerThreads(1); if (StringUtils.isNotBlank(conf.getBookkeeperMetadataServiceUri())) { bkConf.setMetadataServiceUri(conf.getBookkeeperMetadataServiceUri());