This is an automated email from the ASF dual-hosted git repository.
rabreu pushed a change to branch
dependabot/maven/com.fasterxml.jackson-jackson-bom-2.19.1
in repository https://gitbox.apache.org/repos/asf/storm.git
from 60d6d2a89 Fixing licenses
add 1a6ff411d [STORM-8019] Fixing kafka topic level metrics computation
(#8047)
add 8b6d5b097 Bump spring.version from 6.2.7 to 6.2.8 (#8123)
add 6c0178a01 Bump com.fasterxml.jackson.core:jackson-databind from 2.19.0
to 2.19.1 (#8125)
add b63f2322d Merge branch 'master' into
dependabot/maven/com.fasterxml.jackson-jackson-bom-2.19.1
No new revisions were added by this update.
Summary of changes:
DEPENDENCY-LICENSES | 23 +-
examples/storm-jms-examples/pom.xml | 2 +-
.../org/apache/storm/kafka/spout/KafkaSpout.java | 59 ++---
.../spout/metrics2/KafkaOffsetMetricManager.java | 13 +-
.../metrics2/KafkaOffsetPartitionMetrics.java | 185 ++++------------
.../spout/metrics2/KafkaOffsetTopicMetrics.java | 182 +++++++++------
.../kafka/spout/metrics2/KafkaOffsetUtil.java | 92 ++++++++
.../kafka/spout/KafkaSpoutReactivationTest.java | 27 +++
.../metric2/KafkaOffsetPartitionMetricsTest.java | 163 ++++++++++++++
.../spout/metric2/KafkaOffsetTopicMetricsTest.java | 243 +++++++++++++++++++++
10 files changed, 742 insertions(+), 247 deletions(-)
create mode 100644
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetUtil.java
create mode 100644
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/metric2/KafkaOffsetPartitionMetricsTest.java
create mode 100644
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/metric2/KafkaOffsetTopicMetricsTest.java