From fea9bc97786c02c7fc866f499b10766316a4c5cf Mon Sep 17 00:00:00 2001
From: streamnativebot <streamnativebot@streamnative.io>
Date: Fri, 22 Sep 2023 14:44:18 +0000
Subject: [PATCH] "Created by snbot"

---
 docs/amqp-1-0-sink.md   | 36 ++++++++++++-------------
 docs/amqp-1-0-source.md | 36 ++++++++++++-------------
 io-amqp1_0-impl/pom.xml |  2 +-
 pom.xml                 | 60 +++++++++++++++++++----------------------
 tests/Dockerfile        |  2 +-
 tests/pom.xml           |  2 +-
 6 files changed, 66 insertions(+), 72 deletions(-)

diff --git a/docs/amqp-1-0-sink.md b/docs/amqp-1-0-sink.md
index 9bfd8f51..b398b711 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/v3.1.0.4/pulsar-io-amqp1_0-3.1.0.4.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-3.1.0.4.nar
         ```
 
 ## Use it with Function Mesh
@@ -102,7 +102,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-3.1.0.4.nar",
         "parallelism": 1,
         "configs":
         {
@@ -124,7 +124,7 @@ Or:
         "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-3.1.0.4.nar",
         "parallelism": 1,
         "configs": {
             "connection": {
@@ -157,7 +157,7 @@ Or:
     name: "amqp1_0-sink"
     inputs: 
       - "user-op-queue-topic"
-    archive: "connectors/pulsar-io-amqp1_0-{{connector:version}}.nar"
+    archive: "connectors/pulsar-io-amqp1_0-3.1.0.4.nar"
     parallelism: 1
     
     configs:
@@ -177,7 +177,7 @@ Or:
     name: amqp1_0-sink
     inputs:
       - user-op-queue-topic
-    archive: connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    archive: connectors/pulsar-io-amqp1_0-3.1.0.4.nar
     parallelism: 1
     configs:
       connection:
@@ -208,7 +208,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:3.1.0.4
   className: org.apache.pulsar.ecosystem.io.amqp.AmqpSink
   replicas: 1
   input:
@@ -234,7 +234,7 @@ spec:
     cpu: "0.1"
     memory: 1G
   java:
-    jar: connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    jar: connectors/pulsar-io-amqp1_0-3.1.0.4.nar
   clusterName: test-pulsar
   autoAck: true
 ```
@@ -247,7 +247,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:3.1.0.4
   className: org.apache.pulsar.ecosystem.io.amqp.AmqpSink
   replicas: 1
   input:
@@ -279,7 +279,7 @@ spec:
     cpu: "0.1"
     memory: 1G
   java:
-    jar: connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    jar: connectors/pulsar-io-amqp1_0-3.1.0.4.nar
   clusterName: test-pulsar
   autoAck: true
 ```
@@ -301,7 +301,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-3.1.0.4.nar \
 --classname org.apache.pulsar.ecosystem.io.amqp.AmqpSink \
 --sink-config-file amqp-sink-config.yaml
 ```
@@ -323,7 +323,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-3.1.0.4.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.1.0.4.nar
     ```
 
 3. Start Pulsar in standalone mode.
@@ -340,7 +340,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-3.1.0.4.nar
     Searching for functions in /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./functions
     ```
 
@@ -496,7 +496,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-3.1.0.4.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.1.0.4.nar
     ```
 
 2. Reload all [built-in connectors](https://pulsar.apache.org/docs/en/next/io-connectors/).
@@ -546,7 +546,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:3.1.0.4
     className: org.apache.pulsar.ecosystem.io.amqp.AmqpSink
     replicas: 1
     input:
@@ -572,7 +572,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-3.1.0.4.nar
     clusterName: test-pulsar
     autoAck: true
     ```
@@ -583,7 +583,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:3.1.0.4
     className: org.apache.pulsar.ecosystem.io.amqp.AmqpSink
     replicas: 1
     input:
@@ -615,7 +615,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-3.1.0.4.nar
     clusterName: test-pulsar
     autoAck: true
 
diff --git a/docs/amqp-1-0-source.md b/docs/amqp-1-0-source.md
index 8f3f6a6e..4292e0a1 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/v3.1.0.4/pulsar-io-amqp1_0-3.1.0.4.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-3.1.0.4.nar
         ```
 
 ## Use it with Function Mesh
@@ -102,7 +102,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-3.1.0.4.nar",
         "parallelism": 1,
         "configs": {
             "protocol": "amqp",
@@ -124,7 +124,7 @@ or:
         "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-3.1.0.4.nar",
         "parallelism": 1,
         "configs": {
             "connection": {
@@ -156,7 +156,7 @@ or:
         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-3.1.0.4.nar"
         parallelism: 1
         
         configs:
@@ -177,7 +177,7 @@ or
     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-3.1.0.4.nar
     parallelism: 1
     configs:
         connection:
@@ -208,7 +208,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:3.1.0.4
   className: org.apache.pulsar.ecosystem.io.amqp.AmqpSource
   replicas: 1
   output:
@@ -231,7 +231,7 @@ spec:
     cpu: "0.1"
     memory: 1G
   java:
-    jar: connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    jar: connectors/pulsar-io-amqp1_0-3.1.0.4.nar
   clusterName: test-pulsar
 ```
 
@@ -243,7 +243,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:3.1.0.4
   className: org.apache.pulsar.ecosystem.io.amqp.AmqpSource
   replicas: 1
   output:
@@ -272,7 +272,7 @@ spec:
     cpu: "0.1"
     memory: 1G
   java:
-    jar: connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+    jar: connectors/pulsar-io-amqp1_0-3.1.0.4.nar
   clusterName: test-pulsar
 ```
 
@@ -294,7 +294,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-3.1.0.4.nar \
 --classname org.apache.pulsar.ecosystem.io.amqp.AmqpSource \
 --source-config-file amqp-source-config.yaml
 ```
@@ -316,7 +316,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-3.1.0.4.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.1.0.4.nar
     ```
 
 3. Start Pulsar in standalone mode.
@@ -333,7 +333,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-3.1.0.4.nar
     Searching for functions in /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./functions
     ```
 
@@ -482,7 +482,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-3.1.0.4.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.1.0.4.nar
     ```
 
 2. Reload all [built-in connectors](https://pulsar.apache.org/docs/en/next/io-connectors/).
@@ -534,7 +534,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:3.1.0.4
     className: org.apache.pulsar.ecosystem.io.amqp.AmqpSource
     replicas: 1
     output:
@@ -557,7 +557,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-3.1.0.4.nar
     clusterName: test-pulsar
     ```
 
@@ -569,7 +569,7 @@ Or:
     metadata:
     name: amqp-source-sample
     spec:
-    image: streamnative/pulsar-io-amqp-1-0:{{connector:version}}
+    image: streamnative/pulsar-io-amqp-1-0:3.1.0.4
     className: org.apache.pulsar.ecosystem.io.amqp.AmqpSource
     replicas: 1
     output:
@@ -599,7 +599,7 @@ Or:
         cpu: "0.1"
         memory: 1G
     java:
-        jar: connectors/pulsar-io-amqp1_0-{{connector:version}}.nar
+        jar: connectors/pulsar-io-amqp1_0-3.1.0.4.nar
     clusterName: test-pulsar
     ```
 
diff --git a/io-amqp1_0-impl/pom.xml b/io-amqp1_0-impl/pom.xml
index dcbe757c..2940defb 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>3.0.0-SNAPSHOT</version>
+    <version>3.1.0.4</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/pom.xml b/pom.xml
index 863ca609..c5b80b87 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>3.0.0-SNAPSHOT</version>
+  <version>3.1.0.4</version>
   <name>Pulsar Ecosystem :: IO Connector :: AMQP1_0</name>
   <description>This is an Apache Pulsar AMQP1_0 connector</description>
-
   <properties>
     <maven.compiler.source>17</maven.compiler.source>
     <maven.compiler.target>17</maven.compiler.target>
@@ -46,22 +41,19 @@
     <redirectTestOutputToFile>false</redirectTestOutputToFile>
     <spotbugs-annotations.version>3.1.8</spotbugs-annotations.version>
     <testRetryCount>2</testRetryCount>
-
     <!-- connector dependencies -->
     <jackson.version>2.12.6.1</jackson.version>
     <lombok.version>1.18.22</lombok.version>
-    <pulsar.version>3.0.1.2</pulsar.version>
+    <pulsar.version>3.1.0.4</pulsar.version>
     <qpid.version>1.8.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>
@@ -71,7 +63,6 @@
     <puppycrawl.checkstyle.version>6.19</puppycrawl.checkstyle.version>
     <spotbugs-maven-plugin.version>4.2.2</spotbugs-maven-plugin.version>
   </properties>
-
   <licenses>
     <license>
       <name>Apache License, Version 2.0</name>
@@ -79,12 +70,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>
@@ -141,17 +130,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>
@@ -168,7 +154,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>
@@ -180,18 +165,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>
@@ -224,7 +206,6 @@
       <scope>test</scope>
     </dependency>
   </dependencies>
-
   <build>
     <pluginManagement>
       <plugins>
@@ -236,12 +217,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 -->
@@ -362,38 +343,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>
@@ -401,5 +376,24 @@
       </plugin>
     </plugins>
   </build>
-
+  <repositories>
+    <repository>
+      <id>ossrh</id>
+      <url>https://s01.oss.sonatype.org/service/local/repositories/iostreamnative-2531/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 f0a5ecd8..8ba5e3ba 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 023a08e2..42560f38 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>3.0.0-SNAPSHOT</version>
+    <version>3.1.0.4</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>