From 6550ebd2c68c862a1ac9a673efa4fc4c783692a7 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 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; }