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 93b2239 Skip the interceptor for MediaType.MULTIPART_FORM_DATA (#9217)
add ed5d94c [Transaction] Transaction buffer stable position and
lowWaterMark implementation. (#9195)
No new revisions were added by this update.
Summary of changes:
.../apache/bookkeeper/mledger/ManagedCursor.java | 17 +-
.../apache/bookkeeper/mledger/ReadOnlyCursor.java | 4 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 21 +--
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 10 ++
.../bookkeeper/mledger/impl/OpReadEntry.java | 11 +-
.../mledger/impl/ManagedCursorContainerTest.java | 12 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 65 +++++++-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 4 +-
.../broker/TransactionMetadataStoreService.java | 42 +++--
.../broker/service/AbstractBaseDispatcher.java | 69 ++------
.../pulsar/broker/service/AbstractTopic.java | 5 -
.../apache/pulsar/broker/service/ServerCnx.java | 12 +-
.../org/apache/pulsar/broker/service/Topic.java | 14 +-
.../service/nonpersistent/NonPersistentTopic.java | 10 +-
.../service/persistent/MessageDeduplication.java | 2 +-
.../PersistentDispatcherMultipleConsumers.java | 2 +-
.../PersistentDispatcherSingleActiveConsumer.java | 43 +----
.../service/persistent/PersistentReplicator.java | 4 +-
.../broker/service/persistent/PersistentTopic.java | 92 +++++------
.../transaction/buffer/TransactionBuffer.java | 27 +++-
.../buffer/TransactionBufferProvider.java | 5 +-
.../buffer/impl/InMemTransactionBuffer.java | 21 ++-
.../impl/InMemTransactionBufferProvider.java | 7 +-
.../buffer/impl/TopicTransactionBuffer.java | 97 +++++++++--
.../impl/TopicTransactionBufferProvider.java | 12 +-
.../buffer/impl/TransactionBufferClientImpl.java | 16 +-
.../buffer/impl/TransactionBufferDisable.java | 88 ++++++++++
.../buffer/impl/TransactionBufferHandlerImpl.java | 16 +-
.../pulsar/compaction/CompactedTopicImpl.java | 5 +-
.../service/TransactionMarkerDeleteTest.java | 4 +-
...ntStickyKeyDispatcherMultipleConsumersTest.java | 3 +-
.../persistent/PersistentSubscriptionTest.java | 2 +
.../broker/transaction/TransactionConsumeTest.java | 78 ++++++---
.../broker/transaction/TransactionProduceTest.java | 2 +-
.../buffer/TransactionBufferClientTest.java | 12 +-
.../transaction/buffer/TransactionBufferTest.java | 22 +--
.../buffer/TransactionLowWaterMarkTest.java | 161 ++++++++++++++++++
.../buffer/TransactionStablePositionTest.java | 179 +++++++++++++++++++++
.../TransactionCoordinatorClientTest.java | 10 +-
.../client/impl/TransactionEndToEndTest.java | 67 ++++----
.../api/transaction/TransactionBufferClient.java | 12 +-
.../transaction/TransactionCoordinatorClient.java | 13 +-
.../client/impl/TransactionMetaStoreHandler.java | 49 +-----
.../impl/transaction/TransactionBufferHandler.java | 6 +-
.../TransactionCoordinatorClientImpl.java | 18 +--
.../client/impl/transaction/TransactionImpl.java | 12 +-
.../apache/pulsar/common/protocol/Commands.java | 4 +-
.../org/apache/pulsar/common/protocol/Markers.java | 46 ++----
pulsar-common/src/main/proto/PulsarApi.proto | 3 +-
pulsar-common/src/main/proto/PulsarMarkers.proto | 6 -
.../apache/pulsar/common/protocol/MarkersTest.java | 27 +---
.../pulsar/sql/presto/PulsarRecordCursor.java | 2 +-
.../pulsar/sql/presto/TestPulsarConnector.java | 2 +-
.../coordinator/TransactionMetadataStore.java | 10 +-
.../coordinator/impl/MLTransactionLogImpl.java | 2 +-
.../impl/MLTransactionMetadataStore.java | 16 ++
56 files changed, 974 insertions(+), 527 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionBufferDisable.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer/TransactionLowWaterMarkTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/buffer/TransactionStablePositionTest.java
