From 6f9d2ae3ba24576ca0c1d344c25c29eaf272b369 Mon Sep 17 00:00:00 2001
From: chenhang <chenhang@apache.org>
Date: Wed, 21 Apr 2021 18:22:22 +0800
Subject: [PATCH] Bump pulsar to 2.8.0-rc-202104202206

---
 .../streamnative/pulsar/handlers/kop/utils/MetadataUtils.java | 4 +++-
 pom.xml                                                       | 2 +-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/utils/MetadataUtils.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/utils/MetadataUtils.java
index 352134d584..8b7228fa09 100644
--- a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/utils/MetadataUtils.java
+++ b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/utils/MetadataUtils.java
@@ -160,7 +160,9 @@ private static void createKafkaMetadataIfMissing(PulsarAdmin pulsarAdmin,
                 namespaces.setRetention(kafkaMetadataNamespace,
                         new RetentionPolicies((int) conf.getOffsetsRetentionMinutes(), -1));
             }
-            if (namespaces.getCompactionThreshold(kafkaMetadataNamespace) != MAX_COMPACTION_THRESHOLD) {
+
+            Long compactionThreshold = namespaces.getCompactionThreshold(kafkaMetadataNamespace);
+            if (compactionThreshold != null && compactionThreshold != MAX_COMPACTION_THRESHOLD) {
                 namespaces.setCompactionThreshold(kafkaMetadataNamespace, MAX_COMPACTION_THRESHOLD);
             }
 
diff --git a/pom.xml b/pom.xml
index d38b4d210c..06d3eee175 100644
--- a/pom.xml
+++ b/pom.xml
@@ -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.8.0-rc-202102252222</pulsar.version>
+    <pulsar.version>2.8.0-rc-202104202206</pulsar.version>
     <slf4j.version>1.7.25</slf4j.version>
     <spotbugs-annotations.version>3.1.8</spotbugs-annotations.version>
     <testcontainers.version>1.15.1</testcontainers.version>