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 88405242a01 [fix][broker] Don't let a closing topic-policies reader
abort a concurrent cache-init reload (#26132)
new f3818ec533e [improve][broker] Load topic policies on non-persistent
topic load and gate the policy replay (#26134)
new 2a3961b536f [improve][fn] Upgrade pulsar-client-python to 3.13.0
(#26139)
new 407f0ca9827 [fix][sec] Upgrade pulsar-client-go to v0.20.0 in
pulsar-function-go, also address CVEs (#26140)
new b6ed5f134f2 [fix][fn] Reorder Function Worker shutdown to stop
scheduler before runtime manager (#26136)
new 6f42f0c7976 [fix][sec] Bump github.com/go-jose/go-jose/v4 from 4.1.3
to 4.1.4 in /pulsar-function-go (#26142)
new a94a4c5a0e2 [fix][broker][branch-4.0] Fix NOT_FOUND for topic policy
operations on idle non-persistent topics
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:
.github/workflows/ci-go-functions.yaml | 4 +-
pom.xml | 2 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 9 +
.../apache/pulsar/broker/admin/AdminResource.java | 14 ++
.../pulsar/broker/service/AbstractTopic.java | 107 ++++++++++-
.../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 | 64 +++++++
.../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 | 2 +-
22 files changed, 761 insertions(+), 375 deletions(-)
