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 52a2863 Fix cannot consume using older subscriptions if max
subscription limi… (#9758)
add 4e22ef3 [Pulsar Transaction] Transaction buffer lowWaterMark
implementation. (#9722)
No new revisions were added by this update.
Summary of changes:
.../broker/TransactionMetadataStoreService.java | 6 +-
.../apache/pulsar/broker/service/ServerCnx.java | 3 +-
.../apache/pulsar/broker/service/Subscription.java | 2 +-
.../nonpersistent/NonPersistentSubscription.java | 2 +-
.../service/persistent/PersistentSubscription.java | 6 +-
.../buffer/impl/TransactionBufferClientImpl.java | 8 +-
.../buffer/impl/TransactionBufferHandlerImpl.java | 4 +-
.../transaction/pendingack/PendingAckHandle.java | 6 +-
.../pendingack/impl/PendingAckHandleDisabled.java | 4 +-
.../pendingack/impl/PendingAckHandleImpl.java | 38 +++++-
.../persistent/PersistentSubscriptionTest.java | 6 +-
.../buffer/TransactionBufferClientTest.java | 7 +-
.../buffer/TransactionLowWaterMarkTest.java | 129 ++++++++++++++++++++-
.../TransactionCoordinatorClientTest.java | 4 +-
.../pendingack/PendingAckInMemoryDeleteTest.java | 9 +-
.../api/transaction/TransactionBufferClient.java | 16 ++-
.../impl/transaction/TransactionBufferHandler.java | 3 +-
.../apache/pulsar/common/protocol/Commands.java | 3 +-
pulsar-common/src/main/proto/PulsarApi.proto | 1 +
19 files changed, 212 insertions(+), 45 deletions(-)
