Removed unused KafkaConsumer

chinnasamyb · Feb 8, 2018 · c5ca2c4 · c5ca2c4
1 parent 813dd2c
commit c5ca2c4
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/ConsumerGroupLag/src/main/java/com/wushujames/kafka/ConsumerGroupLag.java b/ConsumerGroupLag/src/main/java/com/wushujames/kafka/ConsumerGroupLag.java
@@ -6,7 +6,6 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Properties;
-
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.DefaultParser;
 import org.apache.commons.cli.HelpFormatter;
@@ -106,7 +105,6 @@ public static void main(String[] args) throws JsonProcessingException, OffsetFet
          *   }
          * }
          */
-        try (KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props)) {
             Collection<TopicPartition> c = new ArrayList<TopicPartition>();
 
 
@@ -231,6 +229,5 @@ public static void main(String[] args) throws JsonProcessingException, OffsetFet
                 }
             }
             System.exit(0);
-        }
     }
 }