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/19 02:51:07 UTC

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

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


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

Branch: refs/heads/1.x-branch
Commit: 59073640554e31a098d6c08fd39aa3e910d9a4b3
Parents: 2f3a04d 3e655cb
Author: Jungtaek Lim (HeartSaVioR) <ka...@gmail.com>
Authored: Mon Nov 19 10:53:07 2018 +0900
Committer: Jungtaek Lim (HeartSaVioR) <ka...@gmail.com>
Committed: Mon Nov 19 10:53:07 2018 +0900

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