Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Bump pulsar-io-amqp-1-0 version to 3.1.0-SNAPSHOT #698

Closed
wants to merge 1 commit into from
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
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.1.0-SNAPSHOT/pulsar-io-amqp1_0-3.1.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.1.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.1.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.1.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.1.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.1.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.1.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.1.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.1.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.1.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.1.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.1.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.1.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.1.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.1.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.1.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.1.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.1.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.1.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.1.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.1.0-SNAPSHOT/pulsar-io-amqp1_0-3.1.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.1.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.1.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.1.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.1.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.1.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.1.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.1.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.1.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.1.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.1.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.1.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.1.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.1.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.1.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.1.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.1.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.1.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.1.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.1.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.1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Loading
Loading