You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/06/28 03:29:39 UTC

[pulsar] branch master updated (97e278b753a -> 96237a9615f)

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


    from 97e278b753a [improve][broker][PIP-149]make deleteTopic method async (#16232)
     add 96237a9615f [improve][java-client] Replace ScheduledExecutor to improve performance of message consumption (#16236)

No new revisions were added by this update.

Summary of changes:
 .../broker/transaction/pendingack/PendingAckStore.java  |  4 ++--
 .../pendingack/impl/InMemoryPendingAckStore.java        |  4 ++--
 .../transaction/pendingack/impl/MLPendingAckStore.java  |  4 ++--
 .../pendingack/impl/PendingAckHandleImpl.java           |  4 +---
 .../service/persistent/PersistentSubscriptionTest.java  |  4 ++--
 .../pulsar/client/api/MultiTopicsConsumerTest.java      |  2 +-
 .../org/apache/pulsar/client/impl/ConsumerBase.java     |  9 ++++-----
 .../org/apache/pulsar/client/impl/ConsumerImpl.java     | 13 ++++++++-----
 .../pulsar/client/impl/MultiTopicsConsumerImpl.java     |  4 +++-
 .../org/apache/pulsar/client/impl/PulsarClientImpl.java | 12 +++++++++++-
 .../org/apache/pulsar/client/util/ExecutorProvider.java | 10 ++++++----
 .../pulsar/client/util/ScheduledExecutorProvider.java   | 17 ++++++++---------
 12 files changed, 50 insertions(+), 37 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%)