Update SimpleConsumerExample.java

Bug fix: args number should be 5.
abtpst · Mar 16, 2016 · 6de4fd6 · 6de4fd6
1 parent 0843b38
commit 6de4fd6
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...-clients/consumer/src/main/java/io/confluent/examples/consumer/SimpleConsumerExample.java b/...-clients/consumer/src/main/java/io/confluent/examples/consumer/SimpleConsumerExample.java
@@ -200,12 +200,12 @@ public void run(long maxReads, String topic, int partition, List<String> seedBro
   }
 
   public static void main(String args[]) {
-    if (args.length != 4) {
-      System.out.println("Please provide command line arguments: maxReads partitionId broker port");
+    if (args.length != 5) {
+      System.out.println("Please provide command line arguments: maxReads topic partitionId broker port");
       System.exit(-1);
     }
 
-    long maxReads = Long.parseLong(args[0]);
+    long maxReads = Long.parseLong(args[0]); 
     String topic = args[1];
     int partition = Integer.parseInt(args[2]);
     List<String> seeds = new ArrayList<>();