This is an automated email from the ASF dual-hosted git repository.
rzo1 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
from 9259006a3 [STORM-3771] Execute doCleanup in its own timer thread
without lock. (#3397)
add 40b982227 [STORM-3782] Refactor KafkaOffsetMetric to use V2 metrics
(#3404)
No new revisions were added by this update.
Summary of changes:
.../org/apache/storm/kafka/spout/KafkaSpout.java | 25 ++-
.../kafka/spout/metrics/KafkaOffsetMetric.java | 151 ---------------
.../spout/metrics2/KafkaOffsetMetricManager.java | 85 +++++++++
.../metrics2/KafkaOffsetPartitionMetrics.java | 205 +++++++++++++++++++++
.../spout/metrics2/KafkaOffsetTopicMetrics.java | 139 ++++++++++++++
.../kafka/spout/subscription/TopicAssigner.java | 5 +-
.../kafka/spout/KafkaSpoutReactivationTest.java | 18 +-
.../kafka/spout/KafkaSpoutSingleTopicTest.java | 47 -----
8 files changed, 445 insertions(+), 230 deletions(-)
delete mode 100644
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics/KafkaOffsetMetric.java
create mode 100644
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetMetricManager.java
create mode 100644
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetPartitionMetrics.java
create mode 100644
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetTopicMetrics.java
