diff --git a/kafka-impl/conf/kop.conf b/kafka-impl/conf/kop.conf index f9964f37ea..c71f7f89b5 100755 --- 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 index 602170a03c..6027045a5c 100644 --- 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) {