This is an automated email from the ASF dual-hosted git repository.
xyz pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 43cd22e632d [Java Client] Fix wrong behavior of deduplication for key
based batching (#15413)
new ad868acd689 Rename test file name from *Test2.java to *Test.java
new baf35d2d19c [broker][monitoring] add message ack rate metric for
consumer (#15674)
new 0ea0e2bd075 [Function] provide default error handler for function log
appender (#15728)
new e80d8a05b55 [fix][client] Remove consumer when close consumer command
is received (#15761)
new 49ecd542bbf [Fix][broker] Fix NPE when ledger id not found in
`OpReadEntry` (#15837)
new 03a0da4824e [fix][auth] Generate correct well-known OpenID
configuration URL (#15928)
new 48923ce1811 [fix][client] Remove producer when close producer command
is received (#16028)
new 45ce7bcbcf3 rename
pulsar_producer_configuration_set_crypto_failure_action to
pulsar_producer_configuration_get_crypto_failure_action (#16031)
new b01d5d2da26 [improve][broker] Avoid reconnection when a partitioned
topic was created concurrently (#16043)
new bda2c0514cd [fix][broker] Fix create client with TLS config (#16014)
The 10 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:
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 9 +--
.../bookkeeper/mledger/impl/OpReadEntry.java | 4 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 28 ++++++++
.../org/apache/pulsar/broker/PulsarService.java | 12 ++--
.../pulsar/broker/service/BrokerService.java | 48 ++++++++++---
.../org/apache/pulsar/broker/service/Consumer.java | 26 +++++--
.../apache/pulsar/broker/service/ServerCnx.java | 1 +
.../pulsar/broker/service/StreamingStats.java | 1 +
.../nonpersistent/NonPersistentSubscription.java | 1 +
.../service/nonpersistent/NonPersistentTopic.java | 4 ++
.../service/persistent/PersistentSubscription.java | 1 +
.../broker/service/persistent/PersistentTopic.java | 3 +
.../stats/prometheus/AggregatedConsumerStats.java | 2 +
.../stats/prometheus/AggregatedNamespaceStats.java | 2 +
.../prometheus/AggregatedSubscriptionStats.java | 2 +
.../stats/prometheus/NamespaceStatsAggregator.java | 2 +
.../pulsar/broker/stats/prometheus/TopicStats.java | 7 ++
.../{AdminApiTest2.java => AdminApi2Test.java} | 3 +-
.../pulsar/broker/stats/ConsumerStatsTest.java | 81 ++++++++++++++++++++++
.../pulsar/common/policies/data/ConsumerStats.java | 7 +-
.../common/policies/data/SubscriptionStats.java | 5 ++
pulsar-client-cpp/lib/auth/AuthOauth2.cc | 9 ++-
pulsar-client-cpp/lib/auth/AuthOauth2.h | 1 +
pulsar-client-cpp/lib/c/c_ProducerConfiguration.cc | 2 +-
pulsar-client-cpp/tests/AuthPluginTest.cc | 20 ++++++
.../org/apache/pulsar/client/impl/ClientCnx.java | 11 +--
.../apache/pulsar/client/impl/ClientCnxTest.java | 38 ++++++++++
.../policies/data/stats/ConsumerStatsImpl.java | 8 ++-
.../policies/data/stats/SubscriptionStatsImpl.java | 5 ++
pulsar-common/src/main/proto/PulsarApi.proto | 3 +
.../pulsar/functions/instance/LogAppender.java | 25 +++++--
31 files changed, 327 insertions(+), 44 deletions(-)
rename
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/{AdminApiTest2.java
=> AdminApi2Test.java} (99%)
