You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@storm.apache.org by ka...@apache.org on 2018/11/15 23:16:29 UTC

[4/4] storm git commit: Merge branch 'STORM-3123' of https://github.com/arunmahadevan/storm into STORM-3123

Merge branch 'STORM-3123' of https://github.com/arunmahadevan/storm into STORM-3123


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/29eb449e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/29eb449e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/29eb449e

Branch: refs/heads/master
Commit: 29eb449ee2518d4d2f750fa32b667b671912cbad
Parents: f17b3da d8d8837
Author: Jungtaek Lim (HeartSaVioR) <ka...@gmail.com>
Authored: Fri Nov 16 08:14:47 2018 +0900
Committer: Jungtaek Lim (HeartSaVioR) <ka...@gmail.com>
Committed: Fri Nov 16 08:14:47 2018 +0900

----------------------------------------------------------------------
 .../apache/storm/kafka/spout/KafkaSpout.java    | 23 +++++++-
 .../storm/kafka/monitor/KafkaOffsetLagUtil.java | 14 ++++-
 .../kafka/monitor/NewKafkaSpoutOffsetQuery.java |  9 ++-
 .../apache/storm/utils/TopologySpoutLag.java    | 60 +++++++++++++++++---
 4 files changed, 93 insertions(+), 13 deletions(-)
----------------------------------------------------------------------