This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 08d2445 Fix the batch message ack for WebSocket proxy. (#12530)
new 3cbc79d Functions: add -Dio.netty.tryReflectionSetAccessible=true to
Java functions (#12624)
new 64a63bb Pulsar Functions: detect .nar files and prevent spammy logs
on functions boot (#13) (#12667)
new c08373f [Authorization] Support GET_METADATA topic op after enable
auth (#12656)
new 5fdb94e Allow to configure different implementations for Pulsar
functions state store (#12646)
new f0dc344 k8s runtime: force deletion to avoid hung function worker
during connector restart (#12504)
new 3a31716 allow consume permission to do GetTopics op (#12600)
new f99ff9c [pulsar-perf] Write histogram files for consume command
(#12569)
new c89e1c6 add additional error handling in auto partition update task
MultiTopicsConsumerImpl (#12620)
new ce8f450 [ISSUE-12291][Client] 'StartMessageId' and
'RollbackDuration' not working in MultiTopicsReader for non-partitioned topics
(#12308)
The 9 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 | 4 +
.../authorization/AuthorizationProvider.java | 10 ++
.../MultiRolesTokenAuthorizationProvider.java | 5 +
.../authorization/PulsarAuthorizationProvider.java | 9 ++
.../broker/auth/MockAuthorizationProvider.java | 6 +
.../api/AuthorizationProducerConsumerTest.java | 5 +
.../pulsar/client/impl/MultiTopicsReaderTest.java | 102 ++++++++++++++-
.../impl/PatternTopicsConsumerImplAuthTest.java | 5 +
.../worker/PulsarFunctionLocalRunTest.java | 6 +-
.../worker/PulsarFunctionMetadataStoreTest.java | 122 ++++++++++++++++++
.../apache/pulsar/client/impl/ConsumerImpl.java | 2 +-
.../client/impl/MultiTopicsConsumerImpl.java | 41 +++---
.../client/impl/PartitionedProducerImpl.java | 30 +++--
.../org/apache/pulsar/common/nar/FileUtils.java | 20 +++
pulsar-functions/instance/pom.xml | 6 +
.../functions/instance/JavaInstanceRunnable.java | 16 ++-
.../instance/state/BKStateStoreProviderImpl.java | 2 -
.../state/PulsarMetadataStateStoreImpl.java | 142 +++++++++++++++++++++
.../PulsarMetadataStateStoreProviderImpl.java | 67 ++++++++++
.../instance/state/StateStoreProvider.java | 2 +
.../instance/JavaInstanceRunnableTest.java | 2 +-
....java => PulsarMetadataStateStoreImplTest.java} | 113 +++++++---------
.../org/apache/pulsar/functions/LocalRunner.java | 9 +-
.../functions/runtime/JavaInstanceStarter.java | 4 +
.../pulsar/functions/runtime/RuntimeUtils.java | 3 +
.../runtime/kubernetes/KubernetesRuntime.java | 11 +-
.../kubernetes/KubernetesRuntimeFactory.java | 3 +
.../kubernetes/KubernetesRuntimeFactoryConfig.java | 6 +
.../functions/runtime/thread/ThreadRuntime.java | 33 +++--
.../runtime/thread/ThreadRuntimeFactory.java | 18 ++-
.../pulsar/functions/worker/WorkerConfig.java | 8 ++
.../runtime/kubernetes/KubernetesRuntimeTest.java | 6 +-
.../runtime/process/ProcessRuntimeTest.java | 11 +-
.../worker/rest/api/FunctionsImplTest.java | 4 +-
.../pulsar/testclient/PerformanceConsumer.java | 22 ++++
.../pulsar/testclient/PerformanceProducer.java | 25 ++--
site2/docs/functions-runtime.md | 4 +
site2/docs/performance-pulsar-perf.md | 4 +-
...st.java => GetMetadataOfTopicWithAuthTest.java} | 121 +++++++++---------
....java => GetTopicsOfNamespaceWithAuthTest.java} | 114 ++++++++---------
40 files changed, 860 insertions(+), 263 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionMetadataStoreTest.java
create mode 100644
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/PulsarMetadataStateStoreImpl.java
create mode 100644
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/PulsarMetadataStateStoreProviderImpl.java
copy
pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/state/{BKStateStoreImplTest.java
=> PulsarMetadataStateStoreImplTest.java} (52%)
copy
tests/integration/src/test/java/org/apache/pulsar/tests/integration/auth/admin/{PackagesOpsWithAuthTest.java
=> GetMetadataOfTopicWithAuthTest.java} (64%)
copy
tests/integration/src/test/java/org/apache/pulsar/tests/integration/auth/admin/{PackagesOpsWithAuthTest.java
=> GetTopicsOfNamespaceWithAuthTest.java} (67%)
