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 7, 2023
1 parent bd26858 commit 7ec6f6d
Show file tree
Hide file tree
Showing 6 changed files with 54 additions and 60 deletions.
24 changes: 12 additions & 12 deletions docs/amqp-1-0-sink.md
View file
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.0.1.4/pulsar-io-amqp1_0-3.0.1.4.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.0.1.4.nar
```

## Use it with Function Mesh
Expand Down Expand Up @@ -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-3.0.1.4.nar",
"parallelism": 1,
"configs":
{
Expand All @@ -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-3.0.1.4.nar"
parallelism: 1

configs:
Expand All @@ -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:3.0.1.4
className: org.apache.pulsar.ecosystem.io.amqp.AmqpSink
replicas: 1
input:
Expand All @@ -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-3.0.1.4.nar
clusterName: test-pulsar
autoAck: true
```
Expand All @@ -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-3.0.1.4.nar \
--classname org.apache.pulsar.ecosystem.io.amqp.AmqpSink \
--sink-config-file amqp-sink-config.yaml
```
Expand All @@ -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-3.0.1.4.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.0.1.4.nar
```
3. Start Pulsar in standalone mode.
Expand All @@ -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-3.0.1.4.nar
Searching for functions in /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./functions
```
Expand Down Expand Up @@ -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-3.0.1.4.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.0.1.4.nar
```
2. Reload all [built-in connectors](https://pulsar.apache.org/docs/en/next/io-connectors/).
Expand Down Expand Up @@ -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:3.0.1.4
className: org.apache.pulsar.ecosystem.io.amqp.AmqpSink
replicas: 1
input:
Expand All @@ -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-3.0.1.4.nar
clusterName: test-pulsar
autoAck: true
```
Expand Down
24 changes: 12 additions & 12 deletions docs/amqp-1-0-source.md
View file
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.0.1.4/pulsar-io-amqp1_0-3.0.1.4.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.0.1.4.nar
```

## Use it with Function Mesh
Expand Down Expand Up @@ -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-3.0.1.4.nar",
"parallelism": 1,
"configs": {
"protocol": "amqp",
Expand All @@ -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-3.0.1.4.nar"
parallelism: 1
configs:
Expand All @@ -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:3.0.1.4
className: org.apache.pulsar.ecosystem.io.amqp.AmqpSource
replicas: 1
output:
Expand All @@ -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-3.0.1.4.nar
clusterName: test-pulsar
```

Expand All @@ -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-3.0.1.4.nar \
--classname org.apache.pulsar.ecosystem.io.amqp.AmqpSource \
--source-config-file amqp-source-config.yaml
```
Expand All @@ -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-3.0.1.4.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.0.1.4.nar
```

3. Start Pulsar in standalone mode.
Expand All @@ -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-3.0.1.4.nar
Searching for functions in /Volumes/other/apache-pulsar-2.8.0-SNAPSHOT/./functions
```
Expand Down Expand Up @@ -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-3.0.1.4.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.0.1.4.nar
```
2. Reload all [built-in connectors](https://pulsar.apache.org/docs/en/next/io-connectors/).
Expand Down Expand Up @@ -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:3.0.1.4
className: org.apache.pulsar.ecosystem.io.amqp.AmqpSource
replicas: 1
output:
Expand All @@ -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-3.0.1.4.nar
clusterName: test-pulsar
```
Expand Down
2 changes: 1 addition & 1 deletion io-amqp1_0-impl/pom.xml
View file
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.0.1.4</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Loading

0 comments on commit 7ec6f6d

Please sign in to comment.