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 3ebf727c7da [fix][test] Run makeReadEntryProbFail's errorOrNot on a
caller-provided executor (#26123)
new 0882abeb6ef [improve][broker] Load topic policies on non-persistent
topic load and gate the policy replay (#26134)
new 377be966ffc [improve][fn] Upgrade pulsar-client-python to 3.13.0
(#26139)
new ba7c1ae68c1 [fix][sec] Upgrade pulsar-client-go to v0.20.0 in
pulsar-function-go, also address CVEs (#26140)
new 11d1b096a0d [fix][fn] Reorder Function Worker shutdown to stop
scheduler before runtime manager (#26136)
The 4 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:
.github/workflows/ci-go-functions.yaml | 4 +-
pom.xml | 2 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 9 +
.../pulsar/broker/service/AbstractTopic.java | 106 ++++++++++-
.../SystemTopicBasedTopicPoliciesService.java | 39 +++-
.../broker/service/TopicPolicyListenerWrapper.java | 68 ++++++-
.../service/nonpersistent/NonPersistentTopic.java | 25 +--
.../broker/service/persistent/PersistentTopic.java | 57 +-----
.../admin/MetadataStoreTopicPoliciesTest.java | 8 +
.../pulsar/broker/admin/TopicPoliciesTest.java | 67 +++++++
.../SystemTopicBasedTopicPoliciesServiceTest.java | 63 ++++++
.../service/TopicPolicyListenerWrapperTest.java | 102 +++++++++-
.../service/persistent/PersistentTopicTest.java | 7 +
pulsar-function-go/examples/go.mod | 55 +++---
pulsar-function-go/examples/go.sum | 212 ++++++++++-----------
pulsar-function-go/go.mod | 59 +++---
pulsar-function-go/go.sum | 211 ++++++++++----------
pulsar-function-go/pb/generate.sh | 4 +-
pulsar-function-go/pf/mockMessage_test.go | 4 +
.../functions/worker/PulsarWorkerService.java | 16 +-
tests/docker-images/latest-version-image/pom.xml | 4 +-
21 files changed, 746 insertions(+), 376 deletions(-)
