This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from f844c74 Fix typo of the returned last message ID when the last
message ID is from compacted ledger (#12237)
new f1d3bf1 Upgrade netty to 4.1.68.Final (#12218)
new 44aaa47 Optimize the memory usage of Cache Eviction (#12045)
new 349e4da remove redundant parameters (#12188)
new e3c8386 Fix lost message issues 12221 (#12223)
new 5fad80c [Metrics] Add support for splitting topic and partition label
in Prometheus (#12225)
new c17cd00 fix kinesis connector's dependency issue (#12246)
new b9616e0 [testing] Make python3 the default python in java-test-image
(#12130)
new c947ed4 The loadbalancer should avoid offload the heartbeat namespace
(#12252)
new 8b1edcf Fix cherry-pick issue of #12252
new ce634e2 [stats] Add Key_Shared metadata to topic stats (#11839)
new 2e50783 [Java Client] Use failPendingMessages to ensure proper
cleanup (#12259)
new 2e7088d Fix incorrect returned last message ID while the
`lastConfirmedEntry` with negative entry ID. (#12277)
The 12 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:
buildtools/pom.xml | 2 +-
conf/broker.conf | 9 +
conf/standalone.conf | 9 +
distribution/server/src/assemble/LICENSE.bin.txt | 36 +--
.../mledger/impl/ManagedCursorContainer.java | 38 ++-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 47 ++-
.../mledger/impl/ManagedCursorContainerTest.java | 42 ++-
pom.xml | 4 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 11 +
.../org/apache/pulsar/broker/PulsarService.java | 3 +-
.../broker/loadbalance/impl/OverloadShedder.java | 20 +-
.../broker/loadbalance/impl/ThresholdShedder.java | 15 +-
.../apache/pulsar/broker/service/ServerCnx.java | 66 ++--
.../nonpersistent/NonPersistentSubscription.java | 10 +-
.../PersistentDispatcherSingleActiveConsumer.java | 4 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 6 +-
.../service/persistent/PersistentSubscription.java | 10 +-
.../stats/prometheus/NamespaceStatsAggregator.java | 5 +-
.../prometheus/PrometheusMetricsGenerator.java | 14 +-
.../stats/prometheus/PrometheusMetricsServlet.java | 7 +-
.../pulsar/broker/stats/prometheus/TopicStats.java | 352 ++++++++++++---------
.../pulsar/broker/service/PersistentTopicTest.java | 43 +++
.../pulsar/broker/stats/PrometheusMetricsTest.java | 42 +++
.../pulsar/client/impl/ProducerCloseTest.java | 26 ++
.../pulsar/compaction/CompactedTopicTest.java | 17 +
.../common/policies/data/SubscriptionStats.java | 6 +
.../apache/pulsar/client/impl/ProducerImpl.java | 29 +-
.../policies/data/stats/SubscriptionStatsImpl.java | 7 +
pulsar-io/kinesis/pom.xml | 6 +
pulsar-sql/presto-distribution/LICENSE | 28 +-
tests/docker-images/java-test-image/Dockerfile | 11 +-
31 files changed, 637 insertions(+), 288 deletions(-)
