From 71b257f0e941f1e099dc00630cd25aec97c30df0 Mon Sep 17 00:00:00 2001 From: xiaozhang Date: Mon, 24 Jan 2022 18:12:30 +0800 Subject: [PATCH] HBASE-26701 KafkaProxy enablePeer parameter mismatch --- .../src/main/java/org/apache/hadoop/hbase/kafka/KafkaProxy.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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; }