diff --git a/kafka/hbase-kafka-proxy/src/main/java/org/apache/hadoop/hbase/kafka/KafkaProxy.java b/kafka/hbase-kafka-proxy/src/main/java/org/apache/hadoop/hbase/kafka/KafkaProxy.java
index 5dda9576..ac1f5b1f 100755
--- a/kafka/hbase-kafka-proxy/src/main/java/org/apache/hadoop/hbase/kafka/KafkaProxy.java
+++ b/kafka/hbase-kafka-proxy/src/main/java/org/apache/hadoop/hbase/kafka/KafkaProxy.java
@@ -171,7 +171,7 @@ public static void main(String[] args) throws Exception {
       createPeer = true;
     }
 
-    if (commandLine.hasOption("a")) {
+    if (commandLine.hasOption('e')) {
       enablePeer = true;
     }