This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from dd8ce54c998 [improve][offload] Coalesce automatic offload triggers to
reduce retry loops and ledger scans (#25793)
new 4bfe3efc9af [fix][test] Stabilize
testSecondaryIsolationGroupsBookiesNegative() test (#25900)
new 657f536a578 [improve][misc] Upgrade vert.x to 4.5.28 (#25924)
new 73a0258276f [improve][functions] Allow customizing Kubernetes service
domain suffix in Function Worker (#25872)
new d3690e818a5 [fix][client] Match logical topic when removing unacked
messages (#25921)
new 8ead3bd6a48 [improve][client] Clean up unacked message tracker when
topics are removed in multi-topic consumers (#25923)
new e23e01f7090 [fix][client] Preserve equals in FieldParser map values
(#25907)
new d428118cd14 [fix][fn] Fix orphan exclusive producer on creation
timeout in WorkerUtils.createExclusiveProducerWithRetry (#25942)
The 7 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 | 4 +-
.../client/impl/UnAckedTopicMessageTracker.java | 2 +-
.../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 ++++++++
.../pulsar/functions/worker/WorkerUtils.java | 11 +++-
.../pulsar/functions/worker/WorkerUtilsTest.java | 69 ++++++++++++++++++++++
22 files changed, 327 insertions(+), 27 deletions(-)
