diff --git a/.github/workflows/pr-tests.yml b/.github/workflows/pr-tests.yml
index 36314427d9..3cb9b5b870 100644
--- a/.github/workflows/pr-tests.yml
+++ b/.github/workflows/pr-tests.yml
@@ -16,6 +16,13 @@ jobs:
     runs-on: ubuntu-latest
 
     steps:
+    - uses: s4u/maven-settings-action@v2.6.0
+      with:
+        servers: '[{"id": "ossrh", "username": "${{ secrets.SONATYPE_USERNAME }}",
+          "password": "${{ secrets.SONATYPE_PASSWORD }}"}]'
+    - name: Login to cloudsmith
+      run: docker login -u="${{ secrets.CLOUDSMITH_USERNAME }}" -p="${{ secrets.CLOUDSMITH_API_KEY
+        }}" docker.cloudsmith.io
     - uses: actions/checkout@v1
     - name: Set up JDK 1.8
       uses: actions/setup-java@v1
@@ -51,7 +58,8 @@ jobs:
       run: mvn test -ntp -B -DfailIfNoTests=false -pl oauth-client
 
     - name: tests module
-      run: mvn test -ntp -B -DfailIfNoTests=false '-Dtest=!KafkaIntegration*Test' -pl tests
+      run: mvn test -ntp -B -DfailIfNoTests=false '-Dtest=!KafkaIntegration*Test'
+        -pl tests
       timeout-minutes: 60
 
     - name: package surefire artifacts
diff --git a/.github/workflows/release-note.yml b/.github/workflows/release-note.yml
index bcd5f36465..49af04da6b 100644
--- a/.github/workflows/release-note.yml
+++ b/.github/workflows/release-note.yml
@@ -14,6 +14,13 @@ jobs:
     runs-on: ubuntu-latest
 
     steps:
+    - uses: s4u/maven-settings-action@v2.6.0
+      with:
+        servers: '[{"id": "ossrh", "username": "${{ secrets.SONATYPE_USERNAME }}",
+          "password": "${{ secrets.SONATYPE_PASSWORD }}"}]'
+    - name: Login to cloudsmith
+      run: docker login -u="${{ secrets.CLOUDSMITH_USERNAME }}" -p="${{ secrets.CLOUDSMITH_API_KEY
+        }}" docker.cloudsmith.io
     - uses: s4u/maven-settings-action@v2.6.0
       with:
         servers: '[{"id": "ossrh", "username": "${{ secrets.SONATYPE_USERNAME }}",
diff --git a/kafka-0-10/pom.xml b/kafka-0-10/pom.xml
index fbbebf8f53..1686d2c1d1 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-0-9/pom.xml b/kafka-0-9/pom.xml
index b766b8a865..4a3bfab7c8 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-1-0/pom.xml b/kafka-1-0/pom.xml
index 60463ecfce..200ee321dd 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-2-8/pom.xml b/kafka-2-8/pom.xml
index 0315d32388..fc312d5944 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-3-0/pom.xml b/kafka-3-0/pom.xml
index 9689a447ed..83ac400696 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-client-api/pom.xml b/kafka-client-api/pom.xml
index d84b7e34a7..475e6ef518 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-client-factory/pom.xml b/kafka-client-factory/pom.xml
index 2792ce3be5..1f324a3b67 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-impl/pom.xml b/kafka-impl/pom.xml
index 5ddf04e664..4e21e0a4b5 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
 
   <groupId>io.streamnative.pulsar.handlers</groupId>
diff --git a/kafka-payload-processor-shaded-tests/pom.xml b/kafka-payload-processor-shaded-tests/pom.xml
index d260450b41..54cf6f412a 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-payload-processor-shaded/pom.xml b/kafka-payload-processor-shaded/pom.xml
index 347b56b8b1..75707e23f3 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/kafka-payload-processor/pom.xml b/kafka-payload-processor/pom.xml
index aaaa92d973..214137ec7b 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/oauth-client/pom.xml b/oauth-client/pom.xml
index 75e8c6cb45..f060208069 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
 
   <artifactId>oauth-client</artifactId>
diff --git a/pom.xml b/pom.xml
index d4af2e4dd7..2795e631b5 100644
--- a/pom.xml
+++ b/pom.xml
@@ -24,7 +24,7 @@
   <packaging>pom</packaging>
   <groupId>io.streamnative.pulsar.handlers</groupId>
   <artifactId>pulsar-protocol-handler-kafka-parent</artifactId>
-  <version>2.10.1.9</version>
+  <version>2.10.3.1</version>
   <name>StreamNative :: Pulsar Protocol Handler :: KoP Parent</name>
   <description>Parent for Kafka on Pulsar implemented using Pulsar Protocol Handler.</description>
   <properties>
@@ -37,7 +37,7 @@
     <lombok.version>1.18.24</lombok.version>
     <mockito.version>2.22.0</mockito.version>
     <pulsar.group.id>io.streamnative</pulsar.group.id>
-    <pulsar.version>2.10.1.9</pulsar.version>
+    <pulsar.version>2.10.3.1</pulsar.version>
     <slf4j.version>1.7.25</slf4j.version>
     <spotbugs-annotations.version>3.1.12</spotbugs-annotations.version>
     <testng.version>6.14.3</testng.version>
@@ -134,8 +134,6 @@
         <type>pom</type>
         <scope>import</scope>
       </dependency>
-
-
       <dependency>
         <groupId>junit</groupId>
         <artifactId>junit</artifactId>
@@ -426,6 +424,10 @@
       <layout>default</layout>
       <url>https://repo1.maven.org/maven2</url>
     </repository>
+    <repository>
+      <id>ossrh</id>
+      <url>https://s01.oss.sonatype.org/service/local/repositories/iostreamnative-1917/content</url>
+    </repository>
   </repositories>
   <distributionManagement>
     <snapshotRepository>
diff --git a/test-listener/pom.xml b/test-listener/pom.xml
index a7df5d805d..84d7d290e3 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.10.1.9</version>
+        <version>2.10.3.1</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/tests/pom.xml b/tests/pom.xml
index 08a69e4ed4..6a848c0da0 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.10.1.9</version>
+    <version>2.10.3.1</version>
   </parent>
 
   <groupId>io.streamnative.pulsar.handlers</groupId>