From b64541b2b8a820b0fdc3744185e54c75516734bf Mon Sep 17 00:00:00 2001
From: Yunze Xu <xyzinfernity@163.com>
Date: Sun, 20 Dec 2020 22:36:03 +0800
Subject: [PATCH] Bump pulsar to 2.7.0

---
 kafka-impl/pom.xml                                            | 2 +-
 .../streamnative/pulsar/handlers/kop/KafkaBrokerStarter.java  | 4 +++-
 pom.xml                                                       | 4 ++--
 tests/pom.xml                                                 | 2 +-
 4 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/kafka-impl/pom.xml b/kafka-impl/pom.xml
index a72a3b7c3d..d05b45a50c 100644
--- a/kafka-impl/pom.xml
+++ b/kafka-impl/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>io.streamnative.pulsar.handlers</groupId>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
-    <version>2.6.2-SNAPSHOT</version>
+    <version>2.7.0</version>
   </parent>
 
   <groupId>io.streamnative.pulsar.handlers</groupId>
diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaBrokerStarter.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaBrokerStarter.java
index ed81a971a7..737398a90d 100644
--- a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaBrokerStarter.java
+++ b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaBrokerStarter.java
@@ -36,6 +36,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.apache.bookkeeper.common.util.ReflectionUtils;
 import org.apache.bookkeeper.conf.ServerConfiguration;
+import org.apache.bookkeeper.discover.BookieServiceInfo;
 import org.apache.bookkeeper.proto.BookieServer;
 import org.apache.bookkeeper.replication.AutoRecoveryMain;
 import org.apache.bookkeeper.stats.StatsProvider;
@@ -130,7 +131,8 @@ && isBlank(starterArguments.bookieConfigFile)) {
             if (starterArguments.runBookie) {
                 checkNotNull(bookieConfig, "No ServerConfiguration for Bookie");
                 checkNotNull(bookieStatsProvider, "No Stats Provider for Bookie");
-                bookieServer = new BookieServer(bookieConfig, bookieStatsProvider.getStatsLogger(""));
+                bookieServer = new BookieServer(
+                        bookieConfig, bookieStatsProvider.getStatsLogger(""), BookieServiceInfo.NO_INFO);
             } else {
                 bookieServer = null;
             }
diff --git a/pom.xml b/pom.xml
index 2d7ae109b1..f2056a8c8b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -29,7 +29,7 @@
 
   <groupId>io.streamnative.pulsar.handlers</groupId>
   <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
-  <version>2.6.2-SNAPSHOT</version>
+  <version>2.7.0</version>
   <name>StreamNative :: Pulsar Protocol Handler :: KoP Parent</name>
   <description>Parent for Kafka on Pulsar implemented using Pulsar Protocol Handler.</description>
 
@@ -47,7 +47,7 @@
     <log4j2.version>2.13.3</log4j2.version>
     <lombok.version>1.18.4</lombok.version>
     <mockito.version>2.22.0</mockito.version>
-    <pulsar.version>2.6.2.0</pulsar.version>
+    <pulsar.version>2.7.0</pulsar.version>
     <slf4j.version>1.7.25</slf4j.version>
     <spotbugs-annotations.version>3.1.8</spotbugs-annotations.version>
     <testcontainers.version>1.12.5</testcontainers.version>
diff --git a/tests/pom.xml b/tests/pom.xml
index b52c9222fe..871c4c737f 100644
--- a/tests/pom.xml
+++ b/tests/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>io.streamnative.pulsar.handlers</groupId>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
-    <version>2.6.2-SNAPSHOT</version>
+    <version>2.7.0</version>
   </parent>
 
   <groupId>io.streamnative.pulsar.handlers</groupId>