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 2c1aca12..3ab2e53e 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
@@ -184,7 +184,7 @@ public static void main(String[] args) throws Exception {
       createPeer=true;
     }
 
-    if (commandLine.hasOption("a")){
+    if (commandLine.hasOption("e")){
       enablePeer=true;
     }