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 1d6aa57 Issue 8558: Upgrade Kubernetes client and remove
sundr-codegen (allow Pulsar to run on JDK14+) (#8576)
add 488d384 [Transaction] Transaction buffer snapshot implementation.
(#9490)
No new revisions were added by this update.
Summary of changes:
conf/broker.conf | 7 +
.../apache/pulsar/broker/ServiceConfiguration.java | 19 ++
.../org/apache/pulsar/broker/PulsarService.java | 14 +
.../SystemTopicBaseTxnBufferSnapshotService.java | 86 +++++
.../SystemTopicBasedTopicPoliciesService.java | 31 +-
.../service/TransactionBufferSnapshotService.java | 62 ++++
.../broker/service/persistent/PersistentTopic.java | 122 ++++---
.../NamespaceEventsSystemTopicFactory.java | 24 +-
.../pulsar/broker/systopic/SystemTopicClient.java | 39 ++-
.../broker/systopic/SystemTopicClientBase.java | 26 +-
.../systopic/TopicPoliciesSystemTopicClient.java | 18 +-
.../TransactionBufferSystemTopicClient.java | 178 +++++++++++
.../buffer/TransactionBufferProvider.java | 13 +-
.../buffer/impl/InMemTransactionBuffer.java | 4 +-
.../impl/InMemTransactionBufferProvider.java | 9 +-
.../buffer/impl/TopicTransactionBuffer.java | 352 ++++++++++++++++++++-
.../impl/TopicTransactionBufferProvider.java | 10 +-
.../TopicTransactionBufferRecoverCallBack.java | 36 +--
.../buffer/impl/TopicTransactionBufferState.java | 18 +-
.../buffer/impl/TransactionBufferHandlerImpl.java | 3 +-
.../buffer/matadata/AbortTxnMetadata.java | 18 +-
.../buffer/matadata/TransactionBufferSnapshot.java | 19 +-
.../transaction/buffer/matadata}/package-info.java | 5 +-
.../persistent/PersistentSubscriptionTest.java | 3 +-
.../NamespaceEventsSystemTopicServiceTest.java | 3 +-
.../TopicTransactionBufferRecoverTest.java | 297 +++++++++++++++++
.../broker/transaction/TransactionConsumeTest.java | 1 -
.../broker/transaction/TransactionTestBase.java | 3 +
.../transaction/buffer/TransactionBufferTest.java | 6 +-
.../client/impl/TransactionEndToEndTest.java | 6 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 2 +-
.../org/apache/pulsar/common/events/EventType.java | 7 +-
.../pulsar/common/events/EventsTopicNames.java | 14 +
33 files changed, 1243 insertions(+), 212 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBaseTxnBufferSnapshotService.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TransactionBufferSnapshotService.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TransactionBufferSystemTopicClient.java
copy
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/Event.java
=>
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBufferRecoverCallBack.java
(54%)
copy
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/TransactionMetadataStoreState.java
=>
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBufferState.java
(76%)
copy
pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/CustomBaseObject.java
=>
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/matadata/AbortTxnMetadata.java
(82%)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/DelayedDeliveryPolicies.java
=>
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/matadata/TransactionBufferSnapshot.java
(75%)
copy
{pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web/plugin/servlet
=>
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/matadata}/package-info.java
(88%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/TopicTransactionBufferRecoverTest.java
