diff --git a/.github/workflows/pr_test.yml b/.github/workflows/pr_test.yml
index a847eb2c8..59b7c8d9c 100644
--- a/.github/workflows/pr_test.yml
+++ b/.github/workflows/pr_test.yml
@@ -3,152 +3,180 @@ name: mop mvn build check and ut
 on:
   pull_request:
     branches:
-      - branch-*
-      - master
+    - branch-*
+    - master
     paths-ignore:
-      - 'docs/**'
-      - 'README.md'
+    - 'docs/**'
+    - 'README.md'
   push:
     branches:
-      - branch-*
-      - master
+    - branch-*
+    - master
     paths-ignore:
-      - 'docs/**'
-      - 'README.md'
+    - 'docs/**'
+    - 'README.md'
 
 jobs:
 
   check:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v2
+    - 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@v2
 
-      - name: Cache Maven packages
-        uses: actions/cache@v2
-        with:
-          path: ~/.m2
-          key: ${{ runner.os }}-m2-${{ hashFiles('**/pom.xml') }}
-          restore-keys: ${{ runner.os }}-m2
+    - name: Cache Maven packages
+      uses: actions/cache@v2
+      with:
+        path: ~/.m2
+        key: ${{ runner.os }}-m2-${{ hashFiles('**/pom.xml') }}
+        restore-keys: ${{ runner.os }}-m2
 
-      - name: Set up JDK 1.8
-        uses: actions/setup-java@v1
-        with:
-          java-version: 1.8
+    - name: Set up JDK 1.8
+      uses: actions/setup-java@v1
+      with:
+        java-version: 1.8
 
-      - name: License check
-        run: mvn license:check
+    - name: License check
+      run: mvn license:check
 
-      - name: Build with Maven skipTests
-        run: mvn clean install -DskipTests
+    - name: Build with Maven skipTests
+      run: mvn clean install -DskipTests
 
-      - name: Style check
-        run: mvn checkstyle:check
+    - name: Style check
+      run: mvn checkstyle:check
 
-      - name: Spotbugs check
-        run: mvn spotbugs:check
+    - name: Spotbugs check
+      run: mvn spotbugs:check
 
 
   scan:
     runs-on: ubuntu-latest
     timeout-minutes: 5
     steps:
-      - uses: actions/checkout@v2
-
-      - name: Get All Tests
-        id: list-test
-        run: |
-          TESTS=`find tests/src/test/java/io/streamnative/pulsar/handlers/mqtt \
-          mqtt-impl/src/test/java/io/streamnative/pulsar/handlers/mqtt -name "*Test.java" | \
-          awk -F "/" '{ print $NF }' | \
-          awk -F "." '{ print $1 }' | \
-          jq -R -s -c 'split("\n") | map(select(. != ""))'`
-          echo "::set-output name=tests::$(echo $TESTS)"
+    - 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@v2
+
+    - name: Get All Tests
+      id: list-test
+      run: |
+        TESTS=`find tests/src/test/java/io/streamnative/pulsar/handlers/mqtt \
+        mqtt-impl/src/test/java/io/streamnative/pulsar/handlers/mqtt -name "*Test.java" | \
+        awk -F "/" '{ print $NF }' | \
+        awk -F "." '{ print $1 }' | \
+        jq -R -s -c 'split("\n") | map(select(. != ""))'`
+        echo "::set-output name=tests::$(echo $TESTS)"
     outputs:
       tests: ${{ steps.list-test.outputs.tests }}
 
 
   test:
-    needs: [ scan, check ]
+    needs: [scan, check]
     strategy:
       matrix:
         test: ${{ fromJson(needs.scan.outputs.tests) }}
     runs-on: ubuntu-latest
     timeout-minutes: 20
     steps:
-      - uses: actions/checkout@v2
-
-      - name: Cache Maven packages
-        uses: actions/cache@v2
-        with:
-          path: ~/.m2
-          key: ${{ runner.os }}-m2-${{ hashFiles('**/pom.xml') }}
-          restore-keys: ${{ runner.os }}-m2
-
-      - name: Set up JDK 1.8
-        uses: actions/setup-java@v1
-        with:
-          java-version: 1.8
-
-      - name: Build with Maven skipTests
-        run: mvn clean install -DskipTests
-
-      - name: Test after build
-        run: ./scripts/retry.sh mvn -B -ntp test -Dtest=${{ matrix.test }} -DfailIfNoTests=false
-
-      - name: Upload jacoco artifact
-        uses: actions/upload-artifact@v2
-        with:
-          name: ${{ matrix.test }}-jacoco-artifact
-          path: '**/*.exec'
-          retention-days: 2
-
-      - name: package surefire artifacts
-        if: failure()
-        run: |
-          rm -rf artifacts
-          mkdir artifacts
-          find . -type d -name "*surefire*" -exec cp --parents -R {} artifacts/ \;
-          zip -r ${{ matrix.test }}-artifacts.zip artifacts
-      - uses: actions/upload-artifact@master
-        name: upload surefire-artifacts
-        if: failure()
-        with:
-          name: surefire-artifacts
-          path: ${{ matrix.test }}-artifacts.zip
+    - 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@v2
+
+    - name: Cache Maven packages
+      uses: actions/cache@v2
+      with:
+        path: ~/.m2
+        key: ${{ runner.os }}-m2-${{ hashFiles('**/pom.xml') }}
+        restore-keys: ${{ runner.os }}-m2
+
+    - name: Set up JDK 1.8
+      uses: actions/setup-java@v1
+      with:
+        java-version: 1.8
+
+    - name: Build with Maven skipTests
+      run: mvn clean install -DskipTests
+
+    - name: Test after build
+      run: ./scripts/retry.sh mvn -B -ntp test -Dtest=${{ matrix.test }} -DfailIfNoTests=false
+
+    - name: Upload jacoco artifact
+      uses: actions/upload-artifact@v2
+      with:
+        name: ${{ matrix.test }}-jacoco-artifact
+        path: '**/*.exec'
+        retention-days: 2
+
+    - name: package surefire artifacts
+      if: failure()
+      run: |
+        rm -rf artifacts
+        mkdir artifacts
+        find . -type d -name "*surefire*" -exec cp --parents -R {} artifacts/ \;
+        zip -r ${{ matrix.test }}-artifacts.zip artifacts
+    - uses: actions/upload-artifact@master
+      name: upload surefire-artifacts
+      if: failure()
+      with:
+        name: surefire-artifacts
+        path: ${{ matrix.test }}-artifacts.zip
 
   build:
     needs: test
     runs-on: ubuntu-latest
     timeout-minutes: 10
     steps:
-      - uses: actions/checkout@v2
-
-      - name: Cache Maven packages
-        uses: actions/cache@v2
-        with:
-          path: ~/.m2
-          key: ${{ runner.os }}-m2-${{ hashFiles('**/pom.xml') }}
-          restore-keys: ${{ runner.os }}-m2
-
-      - name: Set up JDK 1.8
-        uses: actions/setup-java@v1
-        with:
-          java-version: 1.8
-
-      - name: Build with Maven skipTests
-        run: mvn clean install -DskipTests
-
-      - name: Download jacoco artifact
-        uses: actions/download-artifact@v2
-        with:
-          path: mqtt-impl/target
-
-      - name: Merge jacoco report
-        run: mvn jacoco:merge
-
-      - name: Generate jacoco report
-        run: mvn jacoco:report
-
-      - name: Upload test report
-        run: bash <(curl -s https://codecov.io/bash)
+    - 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@v2
+
+    - name: Cache Maven packages
+      uses: actions/cache@v2
+      with:
+        path: ~/.m2
+        key: ${{ runner.os }}-m2-${{ hashFiles('**/pom.xml') }}
+        restore-keys: ${{ runner.os }}-m2
+
+    - name: Set up JDK 1.8
+      uses: actions/setup-java@v1
+      with:
+        java-version: 1.8
+
+    - name: Build with Maven skipTests
+      run: mvn clean install -DskipTests
+
+    - name: Download jacoco artifact
+      uses: actions/download-artifact@v2
+      with:
+        path: mqtt-impl/target
+
+    - name: Merge jacoco report
+      run: mvn jacoco:merge
+
+    - name: Generate jacoco report
+      run: mvn jacoco:report
+
+    - name: Upload test report
+      run: bash <(curl -s https://codecov.io/bash)
 
diff --git a/.github/workflows/release-note.yml b/.github/workflows/release-note.yml
index 14fc27626..dc26bc69e 100644
--- a/.github/workflows/release-note.yml
+++ b/.github/workflows/release-note.yml
@@ -3,17 +3,24 @@ name: MoP Release Notes
 on:
   push:
     branches:
-      - master
+    - master
     path-ignores:
-      - 'docs/**'
-      - 'README.md'
+    - 'docs/**'
+    - 'README.md'
 jobs:
   build:
 
     runs-on: ubuntu-latest
 
     steps:
-      - name: release note
-        uses: toolmantim/release-drafter@v5.2.0
-        env:
-          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+    - 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
+    - name: release note
+      uses: toolmantim/release-drafter@v5.2.0
+      env:
+        GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
diff --git a/.github/workflows/release.yml b/.github/workflows/release.yml
index d3c88d0e6..b9d0d56f7 100644
--- a/.github/workflows/release.yml
+++ b/.github/workflows/release.yml
@@ -1,32 +1,39 @@
 name: mqttop Release
 
 on:
-  release:
+  release: null
 
 jobs:
   upload:
     name: Upload Release files
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v1
-      - name: Set up JDK 1.8
-        uses: actions/setup-java@v1
-        with:
-          java-version: 1.8
+    - 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
+      with:
+        java-version: 1.8
 
-      - name: build
-        run: |
-          version=`./scripts/dev/get-project-version.py`
-          mvn clean install -DskipTests
-          rm -rf pulsar-protocol-*
-          cp mqtt-impl/target/pulsar-protocol-handler-mqtt-${version}.nar ./
-          cp README.md ./pulsar-protocol-handler-mqtt-readme.md
-          echo "ls pulsar-protocol-*"
-          ls pulsar-protocol-*
+    - name: build
+      run: |
+        version=`./scripts/dev/get-project-version.py`
+        mvn clean install -DskipTests
+        rm -rf pulsar-protocol-*
+        cp mqtt-impl/target/pulsar-protocol-handler-mqtt-${version}.nar ./
+        cp README.md ./pulsar-protocol-handler-mqtt-readme.md
+        echo "ls pulsar-protocol-*"
+        ls pulsar-protocol-*
 
-      - name: publish
-        uses: skx/github-action-publish-binaries@release-0.11
-        env:
-          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
-        with:
-          args: 'pulsar-protocol-*'
+    - name: publish
+      uses: skx/github-action-publish-binaries@release-0.11
+      env:
+        GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+      with:
+        args: 'pulsar-protocol-*'
diff --git a/mqtt-impl/pom.xml b/mqtt-impl/pom.xml
index 40c693461..17aaba367 100644
--- a/mqtt-impl/pom.xml
+++ b/mqtt-impl/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <artifactId>pulsar-protocol-handler-mqtt-parent</artifactId>
         <groupId>io.streamnative.pulsar.handlers</groupId>
-        <version>2.9.2.14</version>
+        <version>2.9.3.14-rc-iterable</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>pulsar-protocol-handler-mqtt</artifactId>
diff --git a/pom.xml b/pom.xml
index e4e056788..4bbd8ef96 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1,4 +1,4 @@
-<?xml version="1.0" encoding="UTF-8"?>
+<?xml version='1.0' encoding='UTF-8'?>
 <!--
 
     Licensed under the Apache License, Version 2.0 (the "License");
@@ -14,355 +14,349 @@
     limitations under the License.
 
 -->
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <groupId>io.streamnative.pulsar.handlers</groupId>
-    <artifactId>pulsar-protocol-handler-mqtt-parent</artifactId>
-    <version>2.9.2.14</version>
-    <name>StreamNative :: Pulsar Protocol Handler :: MoP Parent</name>
-    <description>Parent for MQTT on Pulsar implemented using Pulsar Protocol Handler.</description>
-
-    <parent>
-        <groupId>org.apache</groupId>
-        <artifactId>apache</artifactId>
-        <version>18</version>
-    </parent>
-    <modelVersion>4.0.0</modelVersion>
-    <packaging>pom</packaging>
-
-    <modules>
-        <module>mqtt-impl</module>
-        <module>tests</module>
-    </modules>
-
-    <licenses>
-        <license>
-            <name>Apache License, Version 2.0</name>
-            <url>http://www.apache.org/licenses/LICENSE-2.0.txt</url>
-            <distribution>repo</distribution>
-        </license>
-    </licenses>
-
-    <properties>
-        <lombok.version>1.18.4</lombok.version>
-        <mockito.version>2.22.0</mockito.version>
-        <testng.version>6.14.3</testng.version>
-        <awaitility.version>4.0.2</awaitility.version>
-        <pulsar.version>2.9.2.14</pulsar.version>
-        <mqtt.codec.version>4.1.74.Final</mqtt.codec.version>
-        <log4j2.version>2.17.1</log4j2.version>
-        <lombok.version>1.18.4</lombok.version>
-        <fusesource.client.version>1.16</fusesource.client.version>
-        <hivemq.mqtt.client.version>1.2.2</hivemq.mqtt.client.version>
-        <apache.commons.bean-utils.version>1.9.4</apache.commons.bean-utils.version>
-        <grpc.version>1.45.1</grpc.version>
-        <!-- plugins -->
-        <javac.target>1.8</javac.target>
-        <puppycrawl.checkstyle.version>8.37</puppycrawl.checkstyle.version>
-        <maven-compiler-plugin.version>3.8.0</maven-compiler-plugin.version>
-        <maven-surefire-plugin.version>3.0.0-M1</maven-surefire-plugin.version>
-        <redirectTestOutputToFile>true</redirectTestOutputToFile>
-        <license-maven-plugin.version>3.0.rc1</license-maven-plugin.version>
-        <maven-checkstyle-plugin.version>3.1.2</maven-checkstyle-plugin.version>
-        <spotbugs-maven-plugin.version>3.1.8</spotbugs-maven-plugin.version>
-        <maven-jacoco-plugin.version>0.8.7</maven-jacoco-plugin.version>
-    </properties>
-
-    <dependencies>
-        <dependency>
-            <groupId>io.streamnative</groupId>
-            <artifactId>pulsar-broker</artifactId>
-            <version>${pulsar.version}</version>
-            <scope>provided</scope>
-            <exclusions>
-                <exclusion>
-                    <groupId>io.grpc</groupId>
-                    <artifactId>grpc-all</artifactId>
-                </exclusion>
-                <exclusion>
-                    <groupId>io.grpc</groupId>
-                    <artifactId>grpc-core</artifactId>
-                </exclusion>
-                <exclusion>
-                    <groupId>io.grpc</groupId>
-                    <artifactId>grpc-testing</artifactId>
-                </exclusion>
-                <exclusion>
-                    <groupId>io.grpc</groupId>
-                    <artifactId>grpc-auth</artifactId>
-                </exclusion>
-            </exclusions>
-        </dependency>
-
-        <dependency>
-            <groupId>io.grpc</groupId>
-            <artifactId>grpc-all</artifactId>
-            <version>${grpc.version}</version>
-            <scope>provided</scope>
-        </dependency>
-
-        <dependency>
-            <groupId>org.apache.logging.log4j</groupId>
-            <artifactId>log4j-core</artifactId>
-            <version>${log4j2.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.logging.log4j</groupId>
-            <artifactId>log4j-slf4j-impl</artifactId>
-            <version>${log4j2.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>org.projectlombok</groupId>
-            <artifactId>lombok</artifactId>
-            <version>${lombok.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>io.netty</groupId>
-            <artifactId>netty-codec-mqtt</artifactId>
-            <version>${mqtt.codec.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>commons-beanutils</groupId>
-            <artifactId>commons-beanutils</artifactId>
-            <version>${apache.commons.bean-utils.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>org.testng</groupId>
-            <artifactId>testng</artifactId>
-            <version>${testng.version}</version>
-            <scope>test</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.awaitility</groupId>
-            <artifactId>awaitility</artifactId>
-            <version>${awaitility.version}</version>
-            <scope>test</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.mockito</groupId>
-            <artifactId>mockito-core</artifactId>
-            <version>${mockito.version}</version>
-            <scope>test</scope>
-        </dependency>
-    </dependencies>
-
-
-    <build>
-        <pluginManagement>
-            <plugins>
-                <plugin>
-                    <groupId>org.apache.maven.plugins</groupId>
-                    <artifactId>maven-checkstyle-plugin</artifactId>
-                    <version>${maven-checkstyle-plugin.version}</version>
-                    <dependencies>
-                        <dependency>
-                            <groupId>com.puppycrawl.tools</groupId>
-                            <artifactId>checkstyle</artifactId>
-                            <version>${puppycrawl.checkstyle.version}</version>
-                        </dependency>
-                    </dependencies>
-                    <configuration>
-                        <configLocation>resources/checkstyle.xml</configLocation>
-                        <suppressionsLocation>resources/suppressions.xml</suppressionsLocation>
-                        <encoding>UTF-8</encoding>
-                        <consoleOutput>true</consoleOutput>
-                        <failOnViolation>true</failOnViolation>
-                        <includeResources>false</includeResources>
-                        <includeTestSourceDirectory>true</includeTestSourceDirectory>
-                    </configuration>
-                    <executions>
-                        <execution>
-                            <id>checkstyle</id>
-                            <phase>validate</phase>
-                            <goals>
-                                <goal>check</goal>
-                            </goals>
-                        </execution>
-                    </executions>
-                </plugin>
-            </plugins>
-        </pluginManagement>
-        <plugins>
-            <plugin>
-                <groupId>com.github.spotbugs</groupId>
-                <artifactId>spotbugs-maven-plugin</artifactId>
-                <version>${spotbugs-maven-plugin.version}</version>
-                <configuration>
-                    <excludeFilterFile>resources/findbugsExclude.xml</excludeFilterFile>
-                </configuration>
-            </plugin>
-            <plugin>
-                <artifactId>maven-compiler-plugin</artifactId>
-                <version>${maven-compiler-plugin.version}</version>
-                <configuration>
-                    <source>${javac.target}</source>
-                    <target>${javac.target}</target>
-                    <compilerArgs>
-                        <!--
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <groupId>io.streamnative.pulsar.handlers</groupId>
+  <artifactId>pulsar-protocol-handler-mqtt-parent</artifactId>
+  <version>2.9.3.14-rc-iterable</version>
+  <name>StreamNative :: Pulsar Protocol Handler :: MoP Parent</name>
+  <description>Parent for MQTT on Pulsar implemented using Pulsar Protocol Handler.</description>
+  <parent>
+    <groupId>org.apache</groupId>
+    <artifactId>apache</artifactId>
+    <version>18</version>
+  </parent>
+  <modelVersion>4.0.0</modelVersion>
+  <packaging>pom</packaging>
+  <modules>
+    <module>mqtt-impl</module>
+    <module>tests</module>
+  </modules>
+  <licenses>
+    <license>
+      <name>Apache License, Version 2.0</name>
+      <url>http://www.apache.org/licenses/LICENSE-2.0.txt</url>
+      <distribution>repo</distribution>
+    </license>
+  </licenses>
+  <properties>
+    <lombok.version>1.18.4</lombok.version>
+    <mockito.version>2.22.0</mockito.version>
+    <testng.version>6.14.3</testng.version>
+    <awaitility.version>4.0.2</awaitility.version>
+    <pulsar.version>2.9.3.14-rc-iterable</pulsar.version>
+    <mqtt.codec.version>4.1.74.Final</mqtt.codec.version>
+    <log4j2.version>2.17.1</log4j2.version>
+    <lombok.version>1.18.4</lombok.version>
+    <fusesource.client.version>1.16</fusesource.client.version>
+    <hivemq.mqtt.client.version>1.2.2</hivemq.mqtt.client.version>
+    <apache.commons.bean-utils.version>1.9.4</apache.commons.bean-utils.version>
+    <grpc.version>1.45.1</grpc.version>
+    <!-- plugins -->
+    <javac.target>1.8</javac.target>
+    <puppycrawl.checkstyle.version>8.37</puppycrawl.checkstyle.version>
+    <maven-compiler-plugin.version>3.8.0</maven-compiler-plugin.version>
+    <maven-surefire-plugin.version>3.0.0-M1</maven-surefire-plugin.version>
+    <redirectTestOutputToFile>true</redirectTestOutputToFile>
+    <license-maven-plugin.version>3.0.rc1</license-maven-plugin.version>
+    <maven-checkstyle-plugin.version>3.1.2</maven-checkstyle-plugin.version>
+    <spotbugs-maven-plugin.version>3.1.8</spotbugs-maven-plugin.version>
+    <maven-jacoco-plugin.version>0.8.7</maven-jacoco-plugin.version>
+  </properties>
+  <dependencies>
+    <dependency>
+      <groupId>io.streamnative</groupId>
+      <artifactId>pulsar-broker</artifactId>
+      <version>${pulsar.version}</version>
+      <scope>provided</scope>
+      <exclusions>
+        <exclusion>
+          <groupId>io.grpc</groupId>
+          <artifactId>grpc-all</artifactId>
+        </exclusion>
+        <exclusion>
+          <groupId>io.grpc</groupId>
+          <artifactId>grpc-core</artifactId>
+        </exclusion>
+        <exclusion>
+          <groupId>io.grpc</groupId>
+          <artifactId>grpc-testing</artifactId>
+        </exclusion>
+        <exclusion>
+          <groupId>io.grpc</groupId>
+          <artifactId>grpc-auth</artifactId>
+        </exclusion>
+      </exclusions>
+    </dependency>
+    <dependency>
+      <groupId>io.grpc</groupId>
+      <artifactId>grpc-all</artifactId>
+      <version>${grpc.version}</version>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.logging.log4j</groupId>
+      <artifactId>log4j-core</artifactId>
+      <version>${log4j2.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.logging.log4j</groupId>
+      <artifactId>log4j-slf4j-impl</artifactId>
+      <version>${log4j2.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>org.projectlombok</groupId>
+      <artifactId>lombok</artifactId>
+      <version>${lombok.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>io.netty</groupId>
+      <artifactId>netty-codec-mqtt</artifactId>
+      <version>${mqtt.codec.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>commons-beanutils</groupId>
+      <artifactId>commons-beanutils</artifactId>
+      <version>${apache.commons.bean-utils.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>org.testng</groupId>
+      <artifactId>testng</artifactId>
+      <version>${testng.version}</version>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.awaitility</groupId>
+      <artifactId>awaitility</artifactId>
+      <version>${awaitility.version}</version>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.mockito</groupId>
+      <artifactId>mockito-core</artifactId>
+      <version>${mockito.version}</version>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+  <build>
+    <pluginManagement>
+      <plugins>
+        <plugin>
+          <groupId>org.apache.maven.plugins</groupId>
+          <artifactId>maven-checkstyle-plugin</artifactId>
+          <version>${maven-checkstyle-plugin.version}</version>
+          <dependencies>
+            <dependency>
+              <groupId>com.puppycrawl.tools</groupId>
+              <artifactId>checkstyle</artifactId>
+              <version>${puppycrawl.checkstyle.version}</version>
+            </dependency>
+          </dependencies>
+          <configuration>
+            <configLocation>resources/checkstyle.xml</configLocation>
+            <suppressionsLocation>resources/suppressions.xml</suppressionsLocation>
+            <encoding>UTF-8</encoding>
+            <consoleOutput>true</consoleOutput>
+            <failOnViolation>true</failOnViolation>
+            <includeResources>false</includeResources>
+            <includeTestSourceDirectory>true</includeTestSourceDirectory>
+          </configuration>
+          <executions>
+            <execution>
+              <id>checkstyle</id>
+              <phase>validate</phase>
+              <goals>
+                <goal>check</goal>
+              </goals>
+            </execution>
+          </executions>
+        </plugin>
+      </plugins>
+    </pluginManagement>
+    <plugins>
+      <plugin>
+        <groupId>com.github.spotbugs</groupId>
+        <artifactId>spotbugs-maven-plugin</artifactId>
+        <version>${spotbugs-maven-plugin.version}</version>
+        <configuration>
+          <excludeFilterFile>resources/findbugsExclude.xml</excludeFilterFile>
+        </configuration>
+      </plugin>
+      <plugin>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <version>${maven-compiler-plugin.version}</version>
+        <configuration>
+          <source>${javac.target}</source>
+          <target>${javac.target}</target>
+          <compilerArgs>
+            <!--
                         <compilerArg>-Werror</compilerArg>
                         -->
-                        <compilerArg>-Xlint:deprecation</compilerArg>
-                        <compilerArg>-Xlint:unchecked</compilerArg>
-                        <!-- https://issues.apache.org/jira/browse/MCOMPILER-205 -->
-                        <compilerArg>-Xpkginfo:always</compilerArg>
-                    </compilerArgs>
-                </configuration>
-            </plugin>
-
-            <plugin>
-                <artifactId>maven-surefire-plugin</artifactId>
-                <version>${maven-surefire-plugin.version}</version>
-                <configuration>
-                    <argLine>@{argLine}
+            <compilerArg>-Xlint:deprecation</compilerArg>
+            <compilerArg>-Xlint:unchecked</compilerArg>
+            <!-- https://issues.apache.org/jira/browse/MCOMPILER-205 -->
+            <compilerArg>-Xpkginfo:always</compilerArg>
+          </compilerArgs>
+        </configuration>
+      </plugin>
+      <plugin>
+        <artifactId>maven-surefire-plugin</artifactId>
+        <version>${maven-surefire-plugin.version}</version>
+        <configuration>
+          <argLine>@{argLine}
                         -Xmx2G
                         -Dpulsar.allocator.pooled=false
                         -Dpulsar.allocator.leak_detection=Advanced
                         -Dlog4j.configurationFile="log4j2.xml"
                     </argLine>
-                    <reuseForks>false</reuseForks>
-                    <forkCount>1</forkCount>
-                    <redirectTestOutputToFile>${redirectTestOutputToFile}</redirectTestOutputToFile>
-                    <trimStackTrace>false</trimStackTrace>
-                </configuration>
-            </plugin>
-
-            <plugin>
-                <groupId>com.mycila</groupId>
-                <artifactId>license-maven-plugin</artifactId>
-                <version>${license-maven-plugin.version}</version>
-                <configuration>
-                    <header>resources/license.template</header>
-
-                    <excludes>
-                        <exclude>LICENSE</exclude>
-                        <exclude>NOTICE</exclude>
-                        <exclude>Jenkinsfile</exclude>
-                        <exclude>resources/license.template</exclude>
-                        <exclude>**/build/**</exclude>
-                        <exclude>**/ahc.properties</exclude>
-                        <exclude>**/.idea/**</exclude>
-                        <exclude>**/.github/**</exclude>
-                    </excludes>
-                    <mapping>
-                        <proto>JAVADOC_STYLE</proto>
-                        <go>DOUBLESLASH_STYLE</go>
-                        <conf>SCRIPT_STYLE</conf>
-                        <ini>SCRIPT_STYLE</ini>
-                        <yaml>SCRIPT_STYLE</yaml>
-                        <tf>SCRIPT_STYLE</tf>
-                        <cfg>SCRIPT_STYLE</cfg>
-                        <Makefile>SCRIPT_STYLE</Makefile>
-                        <service>SCRIPT_STYLE</service>
-                        <cc>JAVADOC_STYLE</cc>
-                        <md>XML_STYLE</md>
-                        <txt>SCRIPT_STYLE</txt>
-                        <scss>JAVADOC_STYLE</scss>
-                        <Doxyfile>SCRIPT_STYLE</Doxyfile>
-                        <tfvars>SCRIPT_STYLE</tfvars>
-                    </mapping>
-                </configuration>
-            </plugin>
-
-            <plugin>
-                <groupId>org.codehaus.mojo</groupId>
-                <artifactId>templating-maven-plugin</artifactId>
-                <version>1.0.0</version>
-                <executions>
-                    <execution>
-                        <id>filtering-java-templates</id>
-                        <goals>
-                            <goal>filter-sources</goal>
-                        </goals>
-                    </execution>
-                </executions>
-            </plugin>
-
-            <plugin>
-                <groupId>pl.project13.maven</groupId>
-                <artifactId>git-commit-id-plugin</artifactId>
-                <version>4.0.0</version>
-                <executions>
-                    <execution>
-                        <id>get-the-git-infos</id>
-                        <goals>
-                            <goal>revision</goal>
-                        </goals>
-                        <phase>initialize</phase>
-                    </execution>
-                </executions>
-                <configuration>
-                    <generateGitPropertiesFile>true</generateGitPropertiesFile>
-                    <generateGitPropertiesFilename>
+          <reuseForks>false</reuseForks>
+          <forkCount>1</forkCount>
+          <redirectTestOutputToFile>${redirectTestOutputToFile}</redirectTestOutputToFile>
+          <trimStackTrace>false</trimStackTrace>
+        </configuration>
+      </plugin>
+      <plugin>
+        <groupId>com.mycila</groupId>
+        <artifactId>license-maven-plugin</artifactId>
+        <version>${license-maven-plugin.version}</version>
+        <configuration>
+          <header>resources/license.template</header>
+          <excludes>
+            <exclude>LICENSE</exclude>
+            <exclude>NOTICE</exclude>
+            <exclude>Jenkinsfile</exclude>
+            <exclude>resources/license.template</exclude>
+            <exclude>**/build/**</exclude>
+            <exclude>**/ahc.properties</exclude>
+            <exclude>**/.idea/**</exclude>
+            <exclude>**/.github/**</exclude>
+          </excludes>
+          <mapping>
+            <proto>JAVADOC_STYLE</proto>
+            <go>DOUBLESLASH_STYLE</go>
+            <conf>SCRIPT_STYLE</conf>
+            <ini>SCRIPT_STYLE</ini>
+            <yaml>SCRIPT_STYLE</yaml>
+            <tf>SCRIPT_STYLE</tf>
+            <cfg>SCRIPT_STYLE</cfg>
+            <Makefile>SCRIPT_STYLE</Makefile>
+            <service>SCRIPT_STYLE</service>
+            <cc>JAVADOC_STYLE</cc>
+            <md>XML_STYLE</md>
+            <txt>SCRIPT_STYLE</txt>
+            <scss>JAVADOC_STYLE</scss>
+            <Doxyfile>SCRIPT_STYLE</Doxyfile>
+            <tfvars>SCRIPT_STYLE</tfvars>
+          </mapping>
+        </configuration>
+      </plugin>
+      <plugin>
+        <groupId>org.codehaus.mojo</groupId>
+        <artifactId>templating-maven-plugin</artifactId>
+        <version>1.0.0</version>
+        <executions>
+          <execution>
+            <id>filtering-java-templates</id>
+            <goals>
+              <goal>filter-sources</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+      <plugin>
+        <groupId>pl.project13.maven</groupId>
+        <artifactId>git-commit-id-plugin</artifactId>
+        <version>4.0.0</version>
+        <executions>
+          <execution>
+            <id>get-the-git-infos</id>
+            <goals>
+              <goal>revision</goal>
+            </goals>
+            <phase>initialize</phase>
+          </execution>
+        </executions>
+        <configuration>
+          <generateGitPropertiesFile>true</generateGitPropertiesFile>
+          <generateGitPropertiesFilename>
                         ${project.build.outputDirectory}/git.properties
                     </generateGitPropertiesFilename>
-                    <includeOnlyProperties>
-                        <includeOnlyProperty>^git.build.(host|time|version)$</includeOnlyProperty>
-                        <includeOnlyProperty>^git.commit.id.(abbrev|full)$</includeOnlyProperty>
-                        <includeOnlyProperty>^git.dirty$</includeOnlyProperty>
-                        <includeOnlyProperty>^git.build.user.(email|name)$</includeOnlyProperty>
-                    </includeOnlyProperties>
-                    <commitIdGenerationMode>full</commitIdGenerationMode>
-                </configuration>
-            </plugin>
-
-            <plugin>
-                <groupId>org.jacoco</groupId>
-                <artifactId>jacoco-maven-plugin</artifactId>
-                <version>${maven-jacoco-plugin.version}</version>
-                <configuration>
-                    <includes>
-                        <include>**/pulsar/**</include>
-                    </includes>
-                    <fileSets>
-                        <fileSet>
-                            <directory>${project.build.directory}</directory>
-                            <includes>
-                                <include>**/*.exec</include>
-                            </includes>
-                        </fileSet>
-                    </fileSets>
-                </configuration>
-                <executions>
-                    <execution>
-                        <goals>
-                            <goal>prepare-agent</goal>
-                        </goals>
-                    </execution>
-                    <execution>
-                        <id>report</id>
-                        <goals>
-                            <goal>report</goal>
-                        </goals>
-                        <phase>none</phase>
-                    </execution>
-                    <execution>
-                        <id>merge-all-jacoco</id>
-                        <goals>
-                            <goal>merge</goal>
-                        </goals>
-                        <phase>none</phase>
-                    </execution>
-                </executions>
-            </plugin>
-
-        </plugins>
-    </build>
-
-    <repositories>
-        <repository>
-            <id>central</id>
-            <layout>default</layout>
-            <url>https://repo1.maven.org/maven2</url>
-        </repository>
-
-        <repository>
-            <snapshots>
-                <enabled>false</enabled>
-            </snapshots>
-            <id>bintray-yahoo-maven</id>
-            <name>bintray</name>
-            <url>https://yahoo.bintray.com/maven</url>
-        </repository>
-    </repositories>
+          <includeOnlyProperties>
+            <includeOnlyProperty>^git.build.(host|time|version)$</includeOnlyProperty>
+            <includeOnlyProperty>^git.commit.id.(abbrev|full)$</includeOnlyProperty>
+            <includeOnlyProperty>^git.dirty$</includeOnlyProperty>
+            <includeOnlyProperty>^git.build.user.(email|name)$</includeOnlyProperty>
+          </includeOnlyProperties>
+          <commitIdGenerationMode>full</commitIdGenerationMode>
+        </configuration>
+      </plugin>
+      <plugin>
+        <groupId>org.jacoco</groupId>
+        <artifactId>jacoco-maven-plugin</artifactId>
+        <version>${maven-jacoco-plugin.version}</version>
+        <configuration>
+          <includes>
+            <include>**/pulsar/**</include>
+          </includes>
+          <fileSets>
+            <fileSet>
+              <directory>${project.build.directory}</directory>
+              <includes>
+                <include>**/*.exec</include>
+              </includes>
+            </fileSet>
+          </fileSets>
+        </configuration>
+        <executions>
+          <execution>
+            <goals>
+              <goal>prepare-agent</goal>
+            </goals>
+          </execution>
+          <execution>
+            <id>report</id>
+            <goals>
+              <goal>report</goal>
+            </goals>
+            <phase>none</phase>
+          </execution>
+          <execution>
+            <id>merge-all-jacoco</id>
+            <goals>
+              <goal>merge</goal>
+            </goals>
+            <phase>none</phase>
+          </execution>
+        </executions>
+      </plugin>
+    </plugins>
+  </build>
+  <repositories>
+    <repository>
+      <id>central</id>
+      <layout>default</layout>
+      <url>https://repo1.maven.org/maven2</url>
+    </repository>
+    <repository>
+      <snapshots>
+        <enabled>false</enabled>
+      </snapshots>
+      <id>bintray-yahoo-maven</id>
+      <name>bintray</name>
+      <url>https://yahoo.bintray.com/maven</url>
+    </repository>
+    <repository>
+      <id>ossrh</id>
+      <url>https://s01.oss.sonatype.org/service/local/repositories/iostreamnative-1693/content</url>
+    </repository>
+  </repositories>
+  <distributionManagement>
+    <snapshotRepository>
+      <id>ossrh</id>
+      <url>https://s01.oss.sonatype.org/content/repositories/snapshots</url>
+    </snapshotRepository>
+    <repository>
+      <id>ossrh</id>
+      <url>https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/</url>
+    </repository>
+  </distributionManagement>
 </project>
diff --git a/tests/pom.xml b/tests/pom.xml
index fe9544ab9..8867ebfef 100644
--- a/tests/pom.xml
+++ b/tests/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <artifactId>pulsar-protocol-handler-mqtt-parent</artifactId>
         <groupId>io.streamnative.pulsar.handlers</groupId>
-        <version>2.9.2.14</version>
+        <version>2.9.3.14-rc-iterable</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>pulsar-protocol-handler-mqtt-tests</artifactId>