Github user vesense commented on a diff in the pull request: https://github.com/apache/storm/pull/2518#discussion_r180281409 --- Diff: external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/spout/RocketMqSpout.java --- @@ -60,14 +58,14 @@ public class RocketMqSpout implements IRichSpout { // TODO add metrics --- End diff -- Thanks. Will update.
---