"Created by snbot"

streamnative · Sep 25, 2023 · 57df7fd · 57df7fd
1 parent 5659147
commit 57df7fd
Show file tree

Hide file tree

Showing 5 changed files with 65 additions and 71 deletions.
diff --git 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.2.0-SNAPSHOT/pulsar-io-amqp1_0-3.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT
   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.2.0-SNAPSHOT.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.2.0-SNAPSHOT
   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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.2.0-SNAPSHOT.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.2.0-SNAPSHOT
     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.2.0-SNAPSHOT.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.2.0-SNAPSHOT
     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.2.0-SNAPSHOT.nar
     clusterName: test-pulsar
     autoAck: true
 

diff --git 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.2.0-SNAPSHOT/pulsar-io-amqp1_0-3.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT
   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.2.0-SNAPSHOT.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.2.0-SNAPSHOT
   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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.2.0-SNAPSHOT.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.2.0-SNAPSHOT.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.2.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.2.0-SNAPSHOT.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.2.0-SNAPSHOT
     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.2.0-SNAPSHOT.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.2.0-SNAPSHOT
     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.2.0-SNAPSHOT.nar
     clusterName: test-pulsar
     ```
 

diff --git 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.2.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>