You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2018/01/03 18:04:43 UTC
[2/2] storm git commit: Merge branch 'kafka-metrics-apache-master' of
https://github.com/omkreddy/storm into asfgit-master
Merge branch 'kafka-metrics-apache-master' of https://github.com/omkreddy/storm into asfgit-master
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/69e596ac
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/69e596ac
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/69e596ac
Branch: refs/heads/master
Commit: 69e596ac60ac152c854c238e98783c57e432d86c
Parents: d644e29 9b2b2db
Author: Stig Rohde Døssing <sr...@apache.org>
Authored: Wed Jan 3 19:02:11 2018 +0100
Committer: Stig Rohde Døssing <sr...@apache.org>
Committed: Wed Jan 3 19:02:11 2018 +0100
----------------------------------------------------------------------
.../apache/storm/kafka/spout/KafkaSpout.java | 27 ++++
.../storm/kafka/spout/KafkaSpoutConfig.java | 22 ++-
.../kafka/spout/internal/OffsetManager.java | 13 +-
.../kafka/spout/metrics/KafkaOffsetMetric.java | 141 +++++++++++++++++++
.../storm/kafka/spout/KafkaSpoutConfigTest.java | 10 ++
.../kafka/spout/KafkaSpoutSingleTopicTest.java | 33 +++++
pom.xml | 2 +-
7 files changed, 245 insertions(+), 3 deletions(-)
----------------------------------------------------------------------