This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 06bd85d Fix compile issue after cherry-pick
new 161f38b Fix kinesis sink backoff class not found (#10744)
new 301a1bd Fix compaction not working for system topic (#10941)
new 2a1078a fix non-persistent topic get partitioned metadata error on
discovery (#10806)
new bea4eb1 [pulsar-broker] Handle multiple topic creation for same
topic-name in broker (#10847)
new 3289ff9 Fix NonRecoverableLedgerException when get last message ID by
Reader (#10957)
The 5 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:
.../broker/admin/impl/PersistentTopicsBase.java | 4 +-
.../pulsar/broker/service/BrokerService.java | 14 +++-
.../apache/pulsar/broker/service/ServerCnx.java | 16 ++++-
.../SystemTopicBasedTopicPoliciesService.java | 12 ++++
.../broker/service/persistent/PersistentTopic.java | 49 ++++++++-----
.../broker/admin/AdminApiGetLastMessageIdTest.java | 44 ++++++++++++
.../pulsar/broker/admin/TopicPoliciesTest.java | 27 ++++++++
.../pulsar/broker/service/ReplicatorTest.java | 81 ++++++++++++++++++++++
.../org/apache/pulsar/common/util/FutureUtil.java | 34 +++++++++
.../discovery/service/BrokerDiscoveryProvider.java | 2 +-
.../discovery/service/BaseDiscoveryTestSetup.java | 8 +++
.../discovery/service/DiscoveryServiceTest.java | 22 ++++++
.../org/apache/pulsar/io/kinesis}/Backoff.java | 11 +--
.../org/apache/pulsar/io/kinesis/KinesisSink.java | 1 -
14 files changed, 295 insertions(+), 30 deletions(-)
copy {pulsar-client/src/main/java/org/apache/pulsar/client/impl =>
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis}/Backoff.java (97%)
