diff --git a/docs/amqp-1-0-sink.md b/docs/amqp-1-0-sink.md
index 775e6906..827c9d4c 100644
--- a/docs/amqp-1-0-sink.md
+++ b/docs/amqp-1-0-sink.md
@@ -15,7 +15,7 @@ You can get the AMQP1_0 sink connector using one of the following methods.
 
 ## Use it with Function Worker
 
-- Download the NAR package from [here](https://github.com/streamnative/pulsar-io-amqp-1-0/releases/download/v{{connector:version}}/pulsar-io-amqp1_0-{{connector:version}}.nar).
+- Download the NAR package from [here](https://github.com/streamnative/pulsar-io-amqp-1-0/releases/download/v2.10.5.4-681bb8/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar).
 
 - Build it from the source code.
 
@@ -35,7 +35,7 @@ You can get the AMQP1_0 sink connector using one of the following methods.
 
         ```bash
         ls pulsar-io-amqp1_0/target
-        pulsar-io-amqp1_0-{{connector:version}}.nar
+        pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
         ```
 
 ## Use it with Function Mesh
@@ -75,7 +75,7 @@ You can create a configuration file (JSON or YAML) to set the properties as belo
         "namespace": "default",
         "name": "amqp1_0-sink",
         "inputs": ["user-op-queue-topic"],
-        "archive": "connectors/pulsar-io-amqp1_0-{{connector:version}}.nar",
+        "archive": "connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar",
         "parallelism": 1,
         "configs":
         {
@@ -96,7 +96,7 @@ You can create a configuration file (JSON or YAML) to set the properties as belo
     name: "amqp1_0-sink"
     inputs: 
       - "user-op-queue-topic"
-    archive: "connectors/pulsar-io-amqp1_0-{{connector:version}}.nar"
+    archive: "connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar"
     parallelism: 1
     
     configs:
@@ -120,7 +120,7 @@ kind: Sink
 metadata:
   name: amqp-sink-sample
 spec:
-  image: streamnative/pulsar-io-amqp-1-0:{{connector:version}}
+  image: streamnative/pulsar-io-amqp-1-0:2.10.5.4-681bb8
   className: org.apache.pulsar.ecosystem.io.amqp.AmqpSink
   replicas: 1
   input:
@@ -146,7 +146,7 @@ spec:
     cpu: "0.1"
     memory: 1G
   java:
-    jar: connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    jar: connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
   clusterName: test-pulsar
   autoAck: true
 ```
@@ -168,7 +168,7 @@ This example shows how to create an AMQP1_0 sink connector on a Pulsar cluster u
 ```
 PULSAR_HOME/bin/pulsar-admin sinks create \
 --name amqp1_0-sink \
---archive pulsar-io-amqp1_0-{{connector:version}}.nar \
+--archive pulsar-io-amqp1_0-2.10.5.4-681bb8.nar \
 --classname org.apache.pulsar.ecosystem.io.amqp.AmqpSink \
 --sink-config-file amqp-sink-config.yaml
 ```
@@ -190,7 +190,7 @@ This example describes how to use the AMQP1_0 sink connector to pull data from P
 2. Copy the NAR package of the AMQP1_0 sink connector to the Pulsar connectors directory.
 
     ```
-    cp pulsar-io-amqp1_0-{{connector:version}}.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    cp pulsar-io-amqp1_0-2.10.5.4-681bb8.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
     ```
 
 3. Start Pulsar in standalone mode.
@@ -207,7 +207,7 @@ This example describes how to use the AMQP1_0 sink connector to pull data from P
 
     ```
     Searching for connectors in /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./connectors
-    Found connector ConnectorDefinition(name=amqp1_0, description=AMQP1_0 source and AMQP1_0 connector, sourceClass=org.apache.pulsar.ecosystem.io.amqp.AmqpSource, sinkClass=org.apache.pulsar.ecosystem.io.amqp.AmqpSink, sourceConfigClass=null, sinkConfigClass=null) from /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    Found connector ConnectorDefinition(name=amqp1_0, description=AMQP1_0 source and AMQP1_0 connector, sourceClass=org.apache.pulsar.ecosystem.io.amqp.AmqpSource, sinkClass=org.apache.pulsar.ecosystem.io.amqp.AmqpSink, sourceConfigClass=null, sinkConfigClass=null) from /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
     Searching for functions in /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./functions
     ```
 
@@ -363,7 +363,7 @@ This example explains how to create an AMQP1_0 sink connector on an on-premises
 1. Copy the NAR package of the AMQP1_0 connector to the Pulsar connectors directory.
 
     ```
-    cp pulsar-io-amqp1_0-{{connector:version}}.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    cp pulsar-io-amqp1_0-2.10.5.4-681bb8.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
     ```
 
 2. Reload all [built-in connectors](https://pulsar.apache.org/docs/en/next/io-connectors/).
@@ -413,7 +413,7 @@ This example demonstrates how to create an AMQP1_0 sink connector through Functi
     metadata:
     name: amqp-sink-sample
     spec:
-    image: streamnative/pulsar-io-amqp-1-0:{{connector:version}}
+    image: streamnative/pulsar-io-amqp-1-0:2.10.5.4-681bb8
     className: org.apache.pulsar.ecosystem.io.amqp.AmqpSink
     replicas: 1
     input:
@@ -439,7 +439,7 @@ This example demonstrates how to create an AMQP1_0 sink connector through Functi
         cpu: "0.1"
         memory: 1G
     java:
-        jar: connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+        jar: connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
     clusterName: test-pulsar
     autoAck: true
     ```
diff --git a/docs/amqp-1-0-source.md b/docs/amqp-1-0-source.md
index 27da9251..c66487df 100644
--- a/docs/amqp-1-0-source.md
+++ b/docs/amqp-1-0-source.md
@@ -15,7 +15,7 @@ You can get the AMQP1_0 source connector using one of the following methods.
 
 ## Use it with Function Worker
 
-- Download the NAR package from [here](https://github.com/streamnative/pulsar-io-amqp-1-0/releases/download/v{{connector:version}}/pulsar-io-amqp1_0-{{connector:version}}.nar).
+- Download the NAR package from [here](https://github.com/streamnative/pulsar-io-amqp-1-0/releases/download/v2.10.5.4-681bb8/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar).
 
 - Build it from the source code.
 
@@ -36,7 +36,7 @@ You can get the AMQP1_0 source connector using one of the following methods.
 
         ```bash
         ls pulsar-io-amqp1_0/target
-        pulsar-io-amqp1_0-{{connector:version}}.nar
+        pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
         ```
 
 ## Use it with Function Mesh
@@ -74,7 +74,7 @@ You can create a configuration file (JSON or YAML) to set the properties as belo
         "namespace": "default",
         "name": "amqp1_0-source",
         "topicName": "user-op-queue-topic",
-        "archive": "connectors/pulsar-io-amqp1_0-{{connector:version}}.nar",
+        "archive": "connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar",
         "parallelism": 1,
         "configs": {
             "protocol": "amqp",
@@ -94,7 +94,7 @@ You can create a configuration file (JSON or YAML) to set the properties as belo
         namespace: "default"
         name: "amqp1_0-source"
         topicName: "user-op-queue-topic"
-        archive: "connectors/pulsar-io-amqp1_0-{{connector:version}}.nar"
+        archive: "connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar"
         parallelism: 1
         
         configs:
@@ -118,7 +118,7 @@ kind: Source
 metadata:
   name: amqp-source-sample
 spec:
-  image: streamnative/pulsar-io-amqp-1-0:{{connector:version}}
+  image: streamnative/pulsar-io-amqp-1-0:2.10.5.4-681bb8
   className: org.apache.pulsar.ecosystem.io.amqp.AmqpSource
   replicas: 1
   output:
@@ -141,7 +141,7 @@ spec:
     cpu: "0.1"
     memory: 1G
   java:
-    jar: connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    jar: connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
   clusterName: test-pulsar
 ```
 
@@ -162,7 +162,7 @@ This example shows how to create an AMQP1_0 source connector on a Pulsar cluster
 ```
 PULSAR_HOME/bin/pulsar-admin sources create \
 --name amqp1_0-source \
---archive pulsar-io-amqp1_0-{{connector:version}}.nar \
+--archive pulsar-io-amqp1_0-2.10.5.4-681bb8.nar \
 --classname org.apache.pulsar.ecosystem.io.amqp.AmqpSource \
 --source-config-file amqp-source-config.yaml
 ```
@@ -184,7 +184,7 @@ This example describes how to use the AMQP1_0 source connector to feed data from
 2. Copy the NAR package of the AMQP1_0 source connector to the Pulsar connectors directory.
 
     ```
-    cp pulsar-io-amqp1_0-{{connector:version}}.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    cp pulsar-io-amqp1_0-2.10.5.4-681bb8.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
     ```
 
 3. Start Pulsar in standalone mode.
@@ -201,7 +201,7 @@ This example describes how to use the AMQP1_0 source connector to feed data from
 
     ```
     Searching for connectors in /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./connectors
-    Found connector ConnectorDefinition(name=amqp1_0, description=AMQP1_0 source and AMQP1_0 connector, sourceClass=org.apache.pulsar.ecosystem.io.amqp.AmqpSource, sinkClass=org.apache.pulsar.ecosystem.io.amqp.AmqpSink, sourceConfigClass=null, sinkConfigClass=null) from /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    Found connector ConnectorDefinition(name=amqp1_0, description=AMQP1_0 source and AMQP1_0 connector, sourceClass=org.apache.pulsar.ecosystem.io.amqp.AmqpSource, sinkClass=org.apache.pulsar.ecosystem.io.amqp.AmqpSink, sourceConfigClass=null, sinkConfigClass=null) from /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
     Searching for functions in /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./functions
     ```
 
@@ -350,7 +350,7 @@ This example explains how to create an AMQP1_0 source connector on an on-premise
 1. Copy the NAR package of the AMQP1_0 connector to the Pulsar connectors directory.
 
     ```
-    cp pulsar-io-amqp1_0-{{connector:version}}.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    cp pulsar-io-amqp1_0-2.10.5.4-681bb8.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
     ```
 
 2. Reload all [built-in connectors](https://pulsar.apache.org/docs/en/next/io-connectors/).
@@ -400,7 +400,7 @@ This example demonstrates how to create an AMQP1_0 source connector through Func
     metadata:
     name: amqp-source-sample
     spec:
-    image: streamnative/pulsar-io-amqp-1-0:{{connector:version}}
+    image: streamnative/pulsar-io-amqp-1-0:2.10.5.4-681bb8
     className: org.apache.pulsar.ecosystem.io.amqp.AmqpSource
     replicas: 1
     output:
@@ -423,7 +423,7 @@ This example demonstrates how to create an AMQP1_0 source connector through Func
         cpu: "0.1"
         memory: 1G
     java:
-        jar: connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+        jar: connectors/pulsar-io-amqp1_0-2.10.5.4-681bb8.nar
     clusterName: test-pulsar
     ```
 
diff --git a/io-amqp1_0-impl/pom.xml b/io-amqp1_0-impl/pom.xml
index 045490f0..c94a4166 100644
--- a/io-amqp1_0-impl/pom.xml
+++ b/io-amqp1_0-impl/pom.xml
@@ -25,7 +25,7 @@
   <parent>
     <artifactId>pulsar-io-amqp1_0-parent</artifactId>
     <groupId>org.apache.pulsar.ecosystem</groupId>
-    <version>2.8.0-rc-202105251229</version>
+    <version>2.10.5.4-681bb8</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/pom.xml b/pom.xml
index e97af76b..ffc306a7 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 to the Apache Software Foundation (ASF) under one
@@ -19,24 +19,19 @@
     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">
+<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">
   <parent>
     <groupId>org.apache</groupId>
     <artifactId>apache</artifactId>
     <version>18</version>
   </parent>
-
   <modelVersion>4.0.0</modelVersion>
-
   <groupId>org.apache.pulsar.ecosystem</groupId>
   <artifactId>pulsar-io-amqp1_0-parent</artifactId>
   <packaging>pom</packaging>
-  <version>2.8.0-rc-202105251229</version>
+  <version>2.10.5.4-681bb8</version>
   <name>Pulsar Ecosystem :: IO Connector :: AMQP1_0</name>
   <description>This is an Apache Pulsar AMQP1_0 connector</description>
-
   <properties>
     <java.version>1.8</java.version>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
@@ -44,22 +39,19 @@
     <redirectTestOutputToFile>false</redirectTestOutputToFile>
     <spotbugs-annotations.version>3.1.8</spotbugs-annotations.version>
     <testRetryCount>2</testRetryCount>
-
     <!-- connector dependencies -->
     <jackson.version>2.9.10.7</jackson.version>
     <lombok.version>1.16.22</lombok.version>
-    <pulsar.version>2.10.5.3</pulsar.version>
+    <pulsar.version>2.10.5.4-681bb8</pulsar.version>
     <qpid.version>0.56.0</qpid.version>
     <log4j2.version>2.17.1</log4j2.version>
     <slf4j.version>1.7.25</slf4j.version>
-
     <!-- test dependencies -->
     <junit.version>4.13.1</junit.version>
     <mockito.version>2.22.0</mockito.version>
     <powermock.version>2.0.0-beta.5</powermock.version>
     <testcontainers.version>1.19.0</testcontainers.version>
     <awaitility.version>4.2.0</awaitility.version>
-
     <!-- build plugin dependencies -->
     <license.plugin.version>3.0</license.plugin.version>
     <maven-checkstyle-plugin.version>3.0.0</maven-checkstyle-plugin.version>
@@ -69,7 +61,6 @@
     <puppycrawl.checkstyle.version>6.19</puppycrawl.checkstyle.version>
     <spotbugs-maven-plugin.version>3.1.8</spotbugs-maven-plugin.version>
   </properties>
-
   <licenses>
     <license>
       <name>Apache License, Version 2.0</name>
@@ -77,12 +68,10 @@
       <distribution>repo</distribution>
     </license>
   </licenses>
-
   <modules>
     <module>io-amqp1_0-impl</module>
     <module>tests</module>
   </modules>
-
   <!-- keep all the dependencies used by all modules here -->
   <dependencyManagement>
     <dependencies>
@@ -139,17 +128,14 @@
       </dependency>
     </dependencies>
   </dependencyManagement>
-
   <!-- include the dependencies -->
   <dependencies>
-
     <!-- connector -->
     <dependency>
       <groupId>org.apache.qpid</groupId>
       <artifactId>qpid-jms-client</artifactId>
       <version>${qpid.version}</version>
     </dependency>
-
     <!-- log -->
     <dependency>
       <groupId>org.slf4j</groupId>
@@ -166,7 +152,6 @@
       <artifactId>log4j-slf4j-impl</artifactId>
       <version>${log4j2.version}</version>
     </dependency>
-
     <!-- provided dependencies (available at compilation and test classpaths and *NOT* packaged) -->
     <dependency>
       <groupId>org.projectlombok</groupId>
@@ -178,18 +163,15 @@
       <artifactId>spotbugs-annotations</artifactId>
       <scope>provided</scope>
     </dependency>
-
     <!-- runtime dependencies -->
     <dependency>
       <groupId>io.streamnative</groupId>
       <artifactId>pulsar-io-core</artifactId>
     </dependency>
-
     <dependency>
       <groupId>com.fasterxml.jackson.core</groupId>
       <artifactId>jackson-databind</artifactId>
     </dependency>
-
     <!-- test dependencies -->
     <dependency>
       <groupId>junit</groupId>
@@ -222,7 +204,6 @@
       <scope>test</scope>
     </dependency>
   </dependencies>
-
   <build>
     <pluginManagement>
       <plugins>
@@ -234,12 +215,12 @@
             <source>${java.version}</source>
             <target>${java.version}</target>
             <compilerArgs>
-<!--              <compilerArg>-Werror</compilerArg>-->
+              <!--              <compilerArg>-Werror</compilerArg>-->
               <compilerArg>-Xlint:deprecation</compilerArg>
               <compilerArg>-Xlint:unchecked</compilerArg>
               <!-- https://issues.apache.org/jira/browse/MCOMPILER-205 -->
               <compilerArg>-Xpkginfo:always</compilerArg>
-	        </compilerArgs>
+            </compilerArgs>
           </configuration>
         </plugin>
         <!-- test -->
@@ -360,38 +341,32 @@
         </plugin>
       </plugins>
     </pluginManagement>
-
     <plugins>
-      <!-- compile --> 
+      <!-- compile -->
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-compiler-plugin</artifactId>
       </plugin>
-
       <!-- test -->
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-surefire-plugin</artifactId>
       </plugin>
-
       <!-- package -->
       <plugin>
         <groupId>org.apache.nifi</groupId>
         <artifactId>nifi-nar-maven-plugin</artifactId>
       </plugin>
-
       <!-- license -->
       <plugin>
         <groupId>com.mycila</groupId>
         <artifactId>license-maven-plugin</artifactId>
       </plugin>
-
       <!-- checkstyle -->
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-checkstyle-plugin</artifactId>
       </plugin>
-
       <!-- spotbugs -->
       <plugin>
         <groupId>com.github.spotbugs</groupId>
@@ -399,5 +374,24 @@
       </plugin>
     </plugins>
   </build>
-
+  <repositories>
+    <repository>
+      <id>ossrh</id>
+      <url>https://s01.oss.sonatype.org/service/local/repositories/iostreamnative-2554/content</url>
+    </repository>
+    <repository>
+      <id>nexus-snapshot</id>
+      <url>https://s01.oss.sonatype.org/content/repositories/snapshots</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/Dockerfile b/tests/Dockerfile
index ea4eeec8..97df3cb8 100644
--- a/tests/Dockerfile
+++ b/tests/Dockerfile
@@ -18,7 +18,7 @@
 #
 
 ARG PULSAR_IMAGE_TAG
-FROM streamnative/pulsar:${PULSAR_IMAGE_TAG}
+FROM docker.cloudsmith.io/streamnative/staging/pulsar:${PULSAR_IMAGE_TAG}
 
 ### Add connector
 COPY ./src/test/resources/pulsar-io-amqp1_0.nar /pulsar/connectors/pulsar-io-amqp1_0.nar
diff --git a/tests/pom.xml b/tests/pom.xml
index d27d59d1..2854b5af 100644
--- a/tests/pom.xml
+++ b/tests/pom.xml
@@ -25,7 +25,7 @@
   <parent>
     <artifactId>pulsar-io-amqp1_0-parent</artifactId>
     <groupId>org.apache.pulsar.ecosystem</groupId>
-    <version>2.8.0-rc-202105251229</version>
+    <version>2.10.5.4-681bb8</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>