Github user VipinRathor commented on a diff in the pull request:
https://github.com/apache/storm/pull/2760#discussion_r204488453
--- Diff:
external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaOffsetLagUtil.java
---
@@ -145,7 +148,8 @@ public static void main(String args[]) {
NewKafkaSpoutOffsetQuery newKafkaSpoutOffsetQuery =
new
NewKafkaSpoutOffsetQuery(commandLine.getOptionValue(OPTION_TOPIC_LONG),
commandLine.getOptionValue(OPTION_BOOTSTRAP_BROKERS_LONG),
-
commandLine.getOptionValue(OPTION_GROUP_ID_LONG), securityProtocol);
+
commandLine.getOptionValue(OPTION_GROUP_ID_LONG), securityProtocol,
--- End diff --
thanks @priyank5485 for review. I'm working on an updated patch. Will
update here soon.
---
