diff --git a/kafka-0-10/pom.xml b/kafka-0-10/pom.xml
index 4bc47731fe..ec80f18b4d 100644
--- a/kafka-0-10/pom.xml
+++ b/kafka-0-10/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
     <groupId>io.streamnative.pulsar.handlers</groupId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-0-9/pom.xml b/kafka-0-9/pom.xml
index 4175beb50e..7e735abe2d 100644
--- a/kafka-0-9/pom.xml
+++ b/kafka-0-9/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
     <groupId>io.streamnative.pulsar.handlers</groupId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-1-0/pom.xml b/kafka-1-0/pom.xml
index 36dca1e4a3..fc7351b242 100644
--- a/kafka-1-0/pom.xml
+++ b/kafka-1-0/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
     <groupId>io.streamnative.pulsar.handlers</groupId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-2-8/pom.xml b/kafka-2-8/pom.xml
index 5f35317075..87ea008d6a 100644
--- a/kafka-2-8/pom.xml
+++ b/kafka-2-8/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
     <groupId>io.streamnative.pulsar.handlers</groupId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-3-0/pom.xml b/kafka-3-0/pom.xml
index 38f5b9641b..857a7ea6c9 100644
--- a/kafka-3-0/pom.xml
+++ b/kafka-3-0/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
     <groupId>io.streamnative.pulsar.handlers</groupId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-client-api/pom.xml b/kafka-client-api/pom.xml
index e6c6c15ef5..c379e4a278 100644
--- a/kafka-client-api/pom.xml
+++ b/kafka-client-api/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
     <groupId>io.streamnative.pulsar.handlers</groupId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-client-factory/pom.xml b/kafka-client-factory/pom.xml
index 8875d78c08..3e0e1441fe 100644
--- a/kafka-client-factory/pom.xml
+++ b/kafka-client-factory/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
     <groupId>io.streamnative.pulsar.handlers</groupId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-impl/pom.xml b/kafka-impl/pom.xml
index eaef9656d5..251b6b0bda 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.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
 
   <groupId>io.streamnative.pulsar.handlers</groupId>
diff --git a/kafka-impl/src/test/java/io/streamnative/pulsar/handlers/kop/utils/OffsetFinderTest.java b/kafka-impl/src/test/java/io/streamnative/pulsar/handlers/kop/utils/OffsetFinderTest.java
index db42f414e5..47cc3d3376 100644
--- a/kafka-impl/src/test/java/io/streamnative/pulsar/handlers/kop/utils/OffsetFinderTest.java
+++ b/kafka-impl/src/test/java/io/streamnative/pulsar/handlers/kop/utils/OffsetFinderTest.java
@@ -13,6 +13,8 @@
  */
 package io.streamnative.pulsar.handlers.kop.utils;
 
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertNotEquals;
 import static org.testng.Assert.assertTrue;
@@ -35,6 +37,7 @@
 import org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl;
 import org.apache.bookkeeper.test.MockedBookKeeperTestCase;
 import org.apache.pulsar.broker.service.persistent.PersistentMessageExpiryMonitor;
+import org.apache.pulsar.broker.service.persistent.PersistentTopic;
 import org.apache.pulsar.common.allocator.PulsarByteBufAllocator;
 import org.apache.pulsar.common.api.proto.MessageMetadata;
 import org.apache.pulsar.common.protocol.ByteBufPair;
@@ -171,8 +174,10 @@ public void findEntryFailed(ManagedLedgerException exception, Optional<Position>
             });
         assertTrue(ex.get());
 
+        PersistentTopic persistentTopic = mock(PersistentTopic.class);
+        when(persistentTopic.getName()).thenReturn("topicname");
         PersistentMessageExpiryMonitor monitor =
-            new PersistentMessageExpiryMonitor("topicname", c1.getName(), c1, null);
+            new PersistentMessageExpiryMonitor(persistentTopic, c1.getName(), c1, null);
         monitor.findEntryFailed(new ManagedLedgerException
             .ConcurrentFindCursorPositionException("failed"), Optional.empty(), null);
         Field field = monitor.getClass().getDeclaredField("expirationCheckInProgress");
diff --git a/kafka-payload-processor-shaded-tests/pom.xml b/kafka-payload-processor-shaded-tests/pom.xml
index 5c7ba7742d..c45147442d 100644
--- a/kafka-payload-processor-shaded-tests/pom.xml
+++ b/kafka-payload-processor-shaded-tests/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
     <groupId>io.streamnative.pulsar.handlers</groupId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-payload-processor-shaded/pom.xml b/kafka-payload-processor-shaded/pom.xml
index 6cae196c7b..0dfb0f40ec 100644
--- a/kafka-payload-processor-shaded/pom.xml
+++ b/kafka-payload-processor-shaded/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
     <groupId>io.streamnative.pulsar.handlers</groupId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-payload-processor/pom.xml b/kafka-payload-processor/pom.xml
index 19823ae323..f34af51940 100644
--- a/kafka-payload-processor/pom.xml
+++ b/kafka-payload-processor/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
     <groupId>io.streamnative.pulsar.handlers</groupId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/oauth-client-shaded-test/pom.xml b/oauth-client-shaded-test/pom.xml
index 1138edbc75..84b00b9093 100644
--- a/oauth-client-shaded-test/pom.xml
+++ b/oauth-client-shaded-test/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>io.streamnative.pulsar.handlers</groupId>
         <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
-        <version>2.11.0-SNAPSHOT</version>
+        <version>3.2.0-SNAPSHOT</version>
     </parent>
 
     <artifactId>oauth-client-shaded-test</artifactId>
diff --git a/oauth-client-shaded/pom.xml b/oauth-client-shaded/pom.xml
index dc611e1164..6ea1dd9ce4 100644
--- a/oauth-client-shaded/pom.xml
+++ b/oauth-client-shaded/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>io.streamnative.pulsar.handlers</groupId>
         <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
-        <version>2.11.0-SNAPSHOT</version>
+        <version>3.2.0-SNAPSHOT</version>
     </parent>
 
     <artifactId>oauth-client</artifactId>
diff --git a/oauth-client/pom.xml b/oauth-client/pom.xml
index 7b1a856d1a..4bd1ab92b9 100644
--- a/oauth-client/pom.xml
+++ b/oauth-client/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
     <groupId>io.streamnative.pulsar.handlers</groupId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
 
   <artifactId>oauth-client-original</artifactId>
diff --git a/pom.xml b/pom.xml
index 9582ab3361..d1023cb0ef 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.11.0-SNAPSHOT</version>
+  <version>3.2.0-SNAPSHOT</version>
   <name>StreamNative :: Pulsar Protocol Handler :: KoP Parent</name>
   <description>Parent for Kafka on Pulsar implemented using Pulsar Protocol Handler.</description>
 
@@ -53,7 +53,7 @@
     <mockito.version>4.11.0</mockito.version>
     <wiremock.version>3.0.0-beta-2</wiremock.version>
     <pulsar.group.id>io.streamnative</pulsar.group.id>
-    <pulsar.version>3.0.0.1</pulsar.version>
+    <pulsar.version>3.1.1.1</pulsar.version>
     <slf4j.version>1.7.25</slf4j.version>
     <spotbugs-annotations.version>3.1.12</spotbugs-annotations.version>
     <apicurio.version>2.1.3.Final</apicurio.version>
diff --git a/schema-registry/pom.xml b/schema-registry/pom.xml
index 3687fa1a72..9eff014e66 100644
--- a/schema-registry/pom.xml
+++ b/schema-registry/pom.xml
@@ -20,7 +20,7 @@
   <parent>
     <groupId>io.streamnative.pulsar.handlers</groupId>
     <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
-    <version>2.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
 
   <groupId>io.streamnative.pulsar.handlers</groupId>
diff --git a/test-listener/pom.xml b/test-listener/pom.xml
index 659ffb024e..9e0e8c3b12 100644
--- a/test-listener/pom.xml
+++ b/test-listener/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
         <groupId>io.streamnative.pulsar.handlers</groupId>
-        <version>2.11.0-SNAPSHOT</version>
+        <version>3.2.0-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/tests/pom.xml b/tests/pom.xml
index ea69b8734d..ef7273c834 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.11.0-SNAPSHOT</version>
+    <version>3.2.0-SNAPSHOT</version>
   </parent>
 
   <groupId>io.streamnative.pulsar.handlers</groupId>
diff --git a/tests/src/test/java/io/streamnative/pulsar/handlers/kop/KopProtocolHandlerTestBase.java b/tests/src/test/java/io/streamnative/pulsar/handlers/kop/KopProtocolHandlerTestBase.java
index fe939f3689..229ec02217 100644
--- a/tests/src/test/java/io/streamnative/pulsar/handlers/kop/KopProtocolHandlerTestBase.java
+++ b/tests/src/test/java/io/streamnative/pulsar/handlers/kop/KopProtocolHandlerTestBase.java
@@ -393,7 +393,6 @@ protected void setupBrokerMocks(PulsarService pulsar) throws Exception {
         doReturn(namespaceServiceSupplier).when(pulsar).getNamespaceServiceProvider();
 
         doReturn(sameThreadOrderedSafeExecutor).when(pulsar).getOrderedExecutor();
-        doAnswer((invocation) -> spy(invocation.callRealMethod())).when(pulsar).newCompactor();
     }
 
     public static MockZooKeeper createMockZooKeeper(String clusterName, String brokerUrl, String brokerUrlTls,