This is an automated email from the ASF dual-hosted git repository.
bogong pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from ad09404ca6d [improve][broker] Reduce the consumers list sort by
priority level (#16243)
new 97fdb483e02 [Client] Support passing existing executor providers to
the client (#12037)
new ca76f455128 [improve][java-client] Replace ScheduledExecutor to
improve performance of message consumption (#16236)
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../transaction/pendingack/PendingAckStore.java | 4 +-
.../pendingack/impl/InMemoryPendingAckStore.java | 4 +-
.../pendingack/impl/MLPendingAckStore.java | 4 +-
.../pendingack/impl/PendingAckHandleImpl.java | 4 +-
.../persistent/PersistentSubscriptionTest.java | 4 +-
.../pulsar/client/api/MultiTopicsConsumerTest.java | 2 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 9 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 13 +-
.../client/impl/MultiTopicsConsumerImpl.java | 48 +++---
.../pulsar/client/impl/PulsarClientImpl.java | 182 ++++++++++++---------
.../pulsar/client/util/ExecutorProvider.java | 10 +-
.../client/util/ScheduledExecutorProvider.java | 17 +-
.../pulsar/client/impl/PulsarClientImplTest.java | 32 ++++
13 files changed, 201 insertions(+), 132 deletions(-)
copy
pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarKafkaSinkContext.java
=>
pulsar-client/src/main/java/org/apache/pulsar/client/util/ScheduledExecutorProvider.java
(66%)
