"Created by snbot"

streamnative · Oct 7, 2023 · 4b11396 · 4b11396
1 parent a90003c
commit 4b11396
Show file tree

Hide file tree

Showing 6 changed files with 54 additions and 60 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/v2.10.5.5/pulsar-io-amqp1_0-2.10.5.5.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.5.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.5.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.5.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.5
   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.5.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.5.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.5.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-2.10.5.5.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.5.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.5.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-2.10.5.5.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.5
     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.5.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/v2.10.5.5/pulsar-io-amqp1_0-2.10.5.5.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.5.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.5.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.5.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.5
   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.5.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.5.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.5.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-2.10.5.5.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.5.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.5.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-2.10.5.5.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.5
     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.5.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>2.8.0-rc-202105251229</version>
+    <version>2.10.5.5</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>