This is an automated email from the ASF dual-hosted git repository.
zhaocong pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 2d0d10c7281 [fix][broker] Fix concurrency bug in
BucketDelayedDeliveryTracker (#25346)
new 86fb07bc458 [fix][test] Fix flaky PulsarDebeziumOracleSourceTest
(#25314)
new fb950f64c19 [fix] Fix flaky
OneWayReplicatorTest.testTopicPoliciesReplicationRule (#25316)
new 11f30ad3039 [fix][client] Fail messages immediately in ProducerImpl
when in terminal state (#25317)
new 45022c44c58 [fix][io][kca] kafka headers silently dropped (#25325)
new aaae5110ead [fix][broker] Handle missing replicator during snapshot
request processing (#25266)
new 5f928c8237a [fix][broker]system topic was created with different
partitions acrossing clusters after enabled namespace-level replication (#25312)
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../pulsar/broker/service/BrokerService.java | 132 +++++++++++++---
.../ReplicatedSubscriptionsController.java | 6 +
.../pulsar/broker/admin/PersistentTopicsTest.java | 6 +
.../broker/service/OneWayReplicatorTest.java | 3 +-
.../service/OneWayReplicatorUsingGlobalZKTest.java | 137 +++++++++++++++++
.../broker/service/TopicTerminationTest.java | 3 +-
.../ReplicatedSubscriptionsControllerTest.java | 168 +++++++++++++++++++++
.../apache/pulsar/client/impl/ProducerImpl.java | 30 +++-
.../kafka/connect/AbstractKafkaConnectSource.java | 5 +-
.../io/kafka/connect/KafkaConnectSource.java | 15 ++
.../io/kafka/connect/KafkaConnectSourceTest.java | 29 ++++
.../debezium/DebeziumOracleDbSourceTester.java | 51 +++++--
12 files changed, 552 insertions(+), 33 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/ReplicatedSubscriptionsControllerTest.java
