This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from a640579a55a [improve][offload] Coalesce automatic offload triggers to
reduce retry loops and ledger scans (#25793)
new edac8b15087 [fix][test] Stabilize
testSecondaryIsolationGroupsBookiesNegative() test (#25900)
new fa9865cd892 [improve][misc] Upgrade vert.x to 4.5.28 (#25924)
new 9ce25e3ce38 [improve][functions] Allow customizing Kubernetes service
domain suffix in Function Worker (#25872)
new b91e2ee3a0f [fix][client] Match logical topic when removing unacked
messages (#25921)
new 45cd065d32f [improve][client] Clean up unacked message tracker when
topics are removed in multi-topic consumers (#25923)
new ae5f410189e [fix][client] Preserve equals in FieldParser map values
(#25907)
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:
conf/functions_worker.yml | 3 ++
distribution/server/src/assemble/LICENSE.bin.txt | 10 ++---
pom.xml | 2 +-
.../IsolatedBookieEnsemblePlacementPolicyTest.java | 6 +++
.../apache/pulsar/client/api/TopicMessageId.java | 13 ++++++
.../client/impl/MultiTopicsConsumerImpl.java | 17 +++++---
.../impl/PatternMultiTopicsConsumerImpl.java | 1 +
.../pulsar/client/impl/TopicMessageIdImpl.java | 7 +++
.../impl/UnAckedTopicMessageRedeliveryTracker.java | 8 ++--
.../client/impl/UnAckedTopicMessageTracker.java | 4 +-
.../client/impl/MultiTopicsConsumerImplTest.java | 51 ++++++++++++++++++++++
.../impl/PatternMultiTopicsConsumerImplTest.java | 41 +++++++++++++++++
.../pulsar/client/impl/TopicMessageIdImplTest.java | 17 ++++++++
.../UnAckedTopicMessageRedeliveryTrackerTest.java | 40 ++++++++++++++++-
.../org/apache/pulsar/common/util/FieldParser.java | 2 +-
.../apache/pulsar/common/util/FieldParserTest.java | 12 +++++
.../runtime/kubernetes/KubernetesRuntime.java | 12 ++---
.../kubernetes/KubernetesRuntimeFactory.java | 4 +-
.../kubernetes/KubernetesRuntimeFactoryConfig.java | 7 ++-
.../runtime/kubernetes/KubernetesRuntimeTest.java | 23 ++++++++++
20 files changed, 253 insertions(+), 27 deletions(-)
