Use OrderedExecutor instead of OrderedScheduler for consumer dispatch
@@ -78,7 +78,6 @@ import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.Setter;
import org.apache.bookkeeper.common.util.OrderedExecutor;
-import org.apache.bookkeeper.common.util.OrderedScheduler;
import org.apache.bookkeeper.mledger.AsyncCallbacks.DeleteLedgerCallback;
import org.apache.bookkeeper.mledger.AsyncCallbacks.OpenLedgerCallback;
import org.apache.bookkeeper.mledger.LedgerOffloader;
@@ -308,7 +307,7 @@ public class BrokerService implements Closeable {
ConcurrentOpenHashMap.<TopicName,
PersistentOfflineTopicStats>newBuilder().build();
- this.topicOrderedExecutor = OrderedScheduler.newSchedulerBuilder()
+ this.topicOrderedExecutor = OrderedExecutor.newBuilder()
.numThreads(pulsar.getConfiguration().getNumWorkerThreadsForNonPersistentTopic())
.name("broker-topic-workers").build();
final DefaultThreadFactory acceptorThreadFactory = new DefaultThreadFactory("pulsar-acceptor");
