You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2024/10/03 08:05:33 UTC
(hbase-connectors) branch master updated: HBASE-26701 KafkaProxy enablePeer parameter mismatch (#139)
This is an automated email from the ASF dual-hosted git repository.
stoty pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase-connectors.git
The following commit(s) were added to refs/heads/master by this push:
new 26cd5f1 HBASE-26701 KafkaProxy enablePeer parameter mismatch (#139)
26cd5f1 is described below
commit 26cd5f143bedcc51441c60efd57fedd152b28512
Author: Istvan Toth <st...@apache.org>
AuthorDate: Thu Oct 3 10:05:27 2024 +0200
HBASE-26701 KafkaProxy enablePeer parameter mismatch (#139)
Co-authored-by: xiaozhang <is...@huolala.cn>
Signed-off-by: Nihal Jain <ni...@apache.org>
Reviewed-by: Istvan Toth <st...@apache.org>
---
.../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 5dda957..ac1f5b1 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 final class KafkaProxy {
createPeer = true;
}
- if (commandLine.hasOption("a")) {
+ if (commandLine.hasOption('e')) {
enablePeer = true;
}