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.

Sign up for GitHub

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

Jump to bottom

Bump pulsar-io-amqp-1-0 version to 3.0.1.0-SNAPSHOT #624

Closed
wants to merge 1 commit into from
Closed

Bump pulsar-io-amqp-1-0 version to 3.0.1.0-SNAPSHOT #624

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
24 changes: 12 additions & 12 deletions docs/amqp-1-0-sink.md
View file
Open in desktop
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.0-SNAPSHOT/pulsar-io-amqp1_0-3.0.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.0.1.0-SNAPSHOT.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.0-SNAPSHOT.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.0-SNAPSHOT.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.0-SNAPSHOT
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.0-SNAPSHOT.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.0-SNAPSHOT.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.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.0.1.0-SNAPSHOT.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.0-SNAPSHOT.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.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.0.1.0-SNAPSHOT.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.0-SNAPSHOT
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.0-SNAPSHOT.nar
clusterName: test-pulsar
autoAck: true
```
Expand Down
24 changes: 12 additions & 12 deletions docs/amqp-1-0-source.md
View file
Open in desktop
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.0-SNAPSHOT/pulsar-io-amqp1_0-3.0.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.0.1.0-SNAPSHOT.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.0-SNAPSHOT.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.0-SNAPSHOT.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.0-SNAPSHOT
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.0-SNAPSHOT.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.0-SNAPSHOT.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.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.0.1.0-SNAPSHOT.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.0-SNAPSHOT.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.0-SNAPSHOT.nar $PULSAR_HOME/connectors/pulsar-io-amqp1_0-3.0.1.0-SNAPSHOT.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.0-SNAPSHOT
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.0-SNAPSHOT.nar
clusterName: test-pulsar
```

Expand Down
2 changes: 1 addition & 1 deletion io-amqp1_0-impl/pom.xml
View file
Open in desktop
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.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>

Expand Down
Loading