bug fix

streamnative · Dec 14, 2020 · a8f9c5d · a8f9c5d
1 parent 8f0c792
commit a8f9c5d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/kafka-impl/conf/kop.conf b/kafka-impl/conf/kop.conf
@@ -72,7 +72,7 @@ offsetsTopicNumPartitions=8
 maxReadEntriesNum=5
 
 # Zookeeper path for storing kop consumer group
-groupIdZooKeeperPath="/client_group_id"
+groupIdZooKeeperPath=/client_group_id
 
 ### --- KoP SSL configs--- ###
 

diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/utils/ZooKeeperUtils.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/utils/ZooKeeperUtils.java
@@ -28,7 +28,7 @@ public static void createPath(ZooKeeper zooKeeper, String zkPath, String subPath
         try {
             if (zooKeeper.exists(zkPath, false) == null) {
                 zooKeeper.create(zkPath,
-                        data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
+                        new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
             }
             String addSubPath = zkPath + subPath;
             if (zooKeeper.exists(addSubPath, false) == null) {