This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 9b27ba2c9b3 [fix][broker]Fix never recovered metadata store bad
version issue if received a large response from ZK (#24580)
new 26a31ac8a5c [improve][build] Disable javadoc build failure (#24594)
new cb5a3abbb94 [fix][broker] Fix memory leak when metrics are updated in
a thread other than FastThreadLocalThread (#24719)
new 498571defe2 [fix][client] Avoid recycling the same
ConcurrentBitSetRecyclable among different threads (#24725)
new bd2ec48bbba [fix][io] Improve Kafka Connect source offset flushing
logic (#24654)
The 4 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:
pom.xml | 2 +
.../metrics/DataSketchesOpStatsLogger.java | 87 +---------
.../metrics/DataSketchesSummaryLogger.java | 49 +-----
.../prometheus/metrics/ThreadLocalAccessor.java | 134 +++++++++++++++
.../metrics/ThreadLocalAccessorTest.java | 92 ++++++++++
.../PersistentAcknowledgmentsGroupingTracker.java | 29 ++--
.../impl/AcknowledgementsGroupingTrackerTest.java | 30 ++--
pulsar-io/kafka-connect-adaptor/pom.xml | 6 +
.../kafka/connect/AbstractKafkaConnectSource.java | 141 +++++++++-------
.../io/kafka/connect/KafkaConnectSourceTest.java | 186 ++++++++++++++++++++-
10 files changed, 534 insertions(+), 222 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/ThreadLocalAccessor.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/prometheus/metrics/ThreadLocalAccessorTest.java
