This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 61f6246 [tests] Pulsar IO - Elasticsearch - reduce elastic container
memory usage (#14580)
new eb779ff [pulsar-io] throw exceptions when kafka offset backing store
failed to start (#14491)
new 7c51c72 [Functions] Pass configured metricsPort to k8s runtime
(#14502)
new cafeade [Flaky-test]: Fix
MLTransactionMetadataStoreTest.testInitTransactionReader fails sporadically
(#14532)
new b093839 [Broker] Fix Broker HealthCheck Endpoint Exposes Race
Conditions (#14367)
new 5228c90 [Flaky-test]: AdminApiTest.testNamespaceSplitBundleConcurrent
(#14565)
new 22cdf21 fix: NamespacesTest execution order (#14552)
new d16f049 [C++] Fix wrong unit of Access Token Response's `expires_in`
field (#14554)
new d3af1ae [OWASP] Update mariadb-jdbc dependency and add suppression
rule (#14593)
new 086d710 [Broker] Fixed wrong behaviour caused by not cleaning up
topic policy service state. (#14503)
new 08a6e9b [C++] Handle exception in creating socket when fd limit is
reached (#14587)
new e0d2f20 [C++] Fix thread safety issue for multi topic consumer
(#14380)
new fd5bc9d Add log to track negtive unacked msg. (#14501)
new e75f0a8 Fix system topic replicate issue (#14605)
new c8a0dff Cancel offload tasks when managed ledger closed. (#14545)
The 14 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 | 1 +
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 9 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 40 +++++
pom.xml | 2 +-
.../pulsar/broker/admin/impl/BrokersBase.java | 129 +++++++++++----
.../org/apache/pulsar/broker/service/Consumer.java | 6 +
.../SystemTopicBasedTopicPoliciesService.java | 53 ++++---
.../broker/admin/AdminApiHealthCheckTest.java | 97 +++++++++++-
.../apache/pulsar/broker/admin/AdminApiTest.java | 7 +-
.../apache/pulsar/broker/admin/NamespacesTest.java | 2 +-
.../service/ReplicatorTopicPoliciesTest.java | 174 ++++++++++++++++++---
pulsar-client-cpp/lib/ClientConnection.cc | 28 +++-
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.cc | 166 +++++++++-----------
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.h | 5 +-
pulsar-client-cpp/lib/SynchronizedHashMap.h | 127 +++++++++++++++
pulsar-client-cpp/lib/auth/AuthOauth2.cc | 15 +-
pulsar-client-cpp/lib/auth/AuthOauth2.h | 5 +-
pulsar-client-cpp/tests/ConsumerTest.cc | 13 +-
pulsar-client-cpp/tests/SynchronizedHashMapTest.cc | 125 +++++++++++++++
.../org/apache/pulsar/common/util/FutureUtil.java | 14 ++
.../runtime/kubernetes/KubernetesRuntime.java | 18 ++-
.../kubernetes/KubernetesRuntimeFactory.java | 7 +-
.../runtime/kubernetes/KubernetesRuntimeTest.java | 52 ++++++
.../functions/worker/FunctionsStatsGenerator.java | 5 +-
.../io/kafka/connect/PulsarOffsetBackingStore.java | 21 ++-
.../impl/MLTransactionMetadataStore.java | 1 +
src/owasp-dependency-check-suppressions.xml | 10 ++
27 files changed, 908 insertions(+), 224 deletions(-)
create mode 100644 pulsar-client-cpp/lib/SynchronizedHashMap.h
create mode 100644 pulsar-client-cpp/tests/SynchronizedHashMapTest.cc
