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 1b790ba Use Awaitility instead Thread.sleep in
InactiveTopicDeleteTest.java (#8647)
add 281163b [Transaction] Add the batch size in transaction ack command.
(#8659)
No new revisions were added by this update.
Summary of changes:
conf/broker.conf | 2 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 2 +-
.../java/org/apache/pulsar/PulsarStandalone.java | 4 +-
.../org/apache/pulsar/broker/service/Consumer.java | 70 ++++++++++----------
.../PersistentDispatcherSingleActiveConsumer.java | 2 +-
.../service/persistent/PersistentSubscription.java | 21 ++----
.../transaction/pendingack/PendingAckHandle.java | 4 +-
.../pendingack/impl/PendingAckHandleDisabled.java | 74 ++++++++++++++++++++++
.../pendingack/impl/PendingAckHandleImpl.java | 34 ++++++----
.../broker/auth/MockedPulsarServiceBaseTest.java | 44 ++++++++-----
.../pulsar/broker/service/BrokerTestBase.java | 10 +++
.../TransactionMetadataStoreServiceTest.java | 5 +-
.../persistent/PersistentSubscriptionTest.java | 17 ++---
.../broker/transaction/TransactionTestBase.java | 1 +
.../coordinator/TransactionMetaStoreTestBase.java | 1 +
.../client/impl/ConsumerAckResponseTest.java | 8 ++-
.../client/impl/TransactionEndToEndTest.java | 15 +++--
.../apache/pulsar/client/impl/ConsumerImpl.java | 20 +++---
.../apache/pulsar/common/api/proto/PulsarApi.java | 57 +++++++++++++++++
.../apache/pulsar/common/protocol/Commands.java | 16 ++++-
pulsar-common/src/main/proto/PulsarApi.proto | 1 +
21 files changed, 294 insertions(+), 114 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/PendingAckHandleDisabled.java
