Skip to content

Commit

Permalink
"Created by snbot"
Browse files Browse the repository at this point in the history
  • Loading branch information
streamnativebot committed Oct 16, 2023
1 parent 5659147 commit 5d89c73
Show file tree
Hide file tree
Showing 5 changed files with 65 additions and 71 deletions.
36 changes: 18 additions & 18 deletions docs/amqp-1-0-sink.md
Original file line number Diff line number Diff line change
Expand Up @@ -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.

Expand All @@ -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
Expand Down Expand Up @@ -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":
{
Expand All @@ -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": {
Expand Down Expand Up @@ -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:
Expand All @@ -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:
Expand Down Expand Up @@ -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:
Expand All @@ -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
```
Expand All @@ -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:
Expand Down Expand Up @@ -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
```
Expand All @@ -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
```
Expand All @@ -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.
Expand All @@ -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
```
Expand Down Expand Up @@ -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/).
Expand Down Expand Up @@ -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:
Expand All @@ -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
```
Expand All @@ -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:
Expand Down Expand Up @@ -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
Expand Down
36 changes: 18 additions & 18 deletions docs/amqp-1-0-source.md
Original file line number Diff line number Diff line change
Expand Up @@ -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.

Expand All @@ -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
Expand Down Expand Up @@ -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",
Expand All @@ -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": {
Expand Down Expand Up @@ -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:
Expand All @@ -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:
Expand Down Expand Up @@ -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:
Expand All @@ -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
```
Expand All @@ -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:
Expand Down Expand Up @@ -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
```
Expand All @@ -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
```
Expand All @@ -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.
Expand All @@ -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
```
Expand Down Expand Up @@ -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/).
Expand Down Expand Up @@ -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:
Expand All @@ -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
```
Expand All @@ -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:
Expand Down Expand Up @@ -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
```
Expand Down
2 changes: 1 addition & 1 deletion io-amqp1_0-impl/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -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>

Expand Down
Loading

0 comments on commit 5d89c73

Please sign in to comment.