Skip to content

Commit

Permalink
Docs sync 20231231 (#385)
Browse files Browse the repository at this point in the history
Co-authored-by: urfreespace <urfreespace@users.noreply.github.com>
  • Loading branch information
streamnativebot and urfreespace authored Jan 2, 2024
1 parent 6c98941 commit 67095e2
Show file tree
Hide file tree
Showing 50 changed files with 650 additions and 532 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ tags: apache-pulsar,pulsar-io,source-connector,sink-connector,apache-activemq
alias: ActiveMQ sink connector
features: ["ActiveMQ Connector integrates Apache Pulsar with Apache ActiveMQ. "]
icon: "/images/connectors/activemq_logo_white_vertical.jpg"
download: https://api.github.com/repos/streamnative/pulsar-io-activemq/tarball/refs/tags/v3.1.1.1
download: https://api.github.com/repos/streamnative/pulsar-io-activemq/tarball/refs/tags/v3.1.1.2
support: streamnative
support_link: https://github.com/streamnative/pulsar-io-activemq
support_img: "https://avatars.githubusercontent.com/u/44651383?v=4"
Expand Down Expand Up @@ -40,16 +40,16 @@ The configuration of the ActiveMQ sink connector has the following properties.

## ActiveMQ sink connector configuration

| Name | Type|Required | Default | Description
|------|----------|----------|---------|-------------|
| `protocol` |String| true | "tcp" | The ActiveMQ protocol. |
| `host` | String| true | " " (empty string) | The ActiveMQ host. |
| `port` | int |true | 5672 | The ActiveMQ port. |
| `username` | String|false | " " (empty string) | The username used to authenticate to ActiveMQ. |
| `password` | String|false | " " (empty string) | The password used to authenticate to ActiveMQ. |
| `queueName` | String|false | " " (empty string) | The ActiveMQ queue name that messages should be read from or written to. |
| `topicName` | String|false | " " (empty string) | The ActiveMQ topic name that messages should be read from or written to. |
| `activeMessageType` | String|false |0 | The ActiveMQ message simple class name. |
| Name | Type | Required | Sensitive | Default | Description |
|---------------------|--------|----------|-----------|--------------------|--------------------------------------------------------------------------|
| `protocol` | String | true | false | "tcp" | The ActiveMQ protocol. |
| `host` | String | true | false | " " (empty string) | The ActiveMQ host. |
| `port` | int | true | false | 5672 | The ActiveMQ port. |
| `username` | String | false | true | " " (empty string) | The username used to authenticate to ActiveMQ. |
| `password` | String | false | true | " " (empty string) | The password used to authenticate to ActiveMQ. |
| `queueName` | String | false | false | " " (empty string) | The ActiveMQ queue name that messages should be read from or written to. |
| `topicName` | String | false | false | " " (empty string) | The ActiveMQ topic name that messages should be read from or written to. |
| `activeMessageType` | String | false | false | 0 | The ActiveMQ message simple class name. |

## Configure ActiveMQ sink connector

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ tags: apache-pulsar,pulsar-io,source-connector,sink-connector,apache-activemq
alias: ActiveMQ source connector
features: ["ActiveMQ Connector integrates Apache Pulsar with Apache ActiveMQ. "]
icon: "/images/connectors/activemq_logo_white_vertical.jpg"
download: https://api.github.com/repos/streamnative/pulsar-io-activemq/tarball/refs/tags/v3.1.1.1
download: https://api.github.com/repos/streamnative/pulsar-io-activemq/tarball/refs/tags/v3.1.1.2
support: streamnative
support_link: https://github.com/streamnative/pulsar-io-activemq
support_img: "https://avatars.githubusercontent.com/u/44651383?v=4"
Expand Down Expand Up @@ -40,15 +40,15 @@ The configuration of the ActiveMQ source connector has the following properties.

## ActiveMQ source connector configuration

| Name | Type|Required | Default | Description
|------|----------|----------|---------|-------------|
| `protocol` |String| true | "tcp" | The ActiveMQ protocol. |
| `host` | String| true | " " (empty string) | The ActiveMQ host. |
| `port` | int |true | 5672 | The ActiveMQ port. |
| `username` | String|false | " " (empty string) | The username used to authenticate to ActiveMQ. |
| `password` | String|false | " " (empty string) | The password used to authenticate to ActiveMQ. |
| `queueName` | String|false | " " (empty string) | The ActiveMQ queue name that messages should be read from or written to. |
| `topicName` | String|false | " " (empty string) | The ActiveMQ topic name that messages should be read from or written to. |
| Name | Type | Required | Sensitive | Default | Description |
|-------------|--------|----------|-----------|--------------------|--------------------------------------------------------------------------|
| `protocol` | String | true | false | "tcp" | The ActiveMQ protocol. |
| `host` | String | true | false | " " (empty string) | The ActiveMQ host. |
| `port` | int | true | false | 5672 | The ActiveMQ port. |
| `username` | String | false | true | " " (empty string) | The username used to authenticate to ActiveMQ. |
| `password` | String | false | true | " " (empty string) | The password used to authenticate to ActiveMQ. |
| `queueName` | String | false | false | " " (empty string) | The ActiveMQ queue name that messages should be read from or written to. |
| `topicName` | String | false | false | " " (empty string) | The ActiveMQ topic name that messages should be read from or written to. |

## Configure ActiveMQ source connector

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,14 +4,14 @@ author: ["ASF"]
contributors: ["ASF"]
language: Java
document: sss
source: "https://github.com/streamnative/pulsar/tree/v3.1.1.1/pulsar-io/aerospike"
source: "https://github.com/streamnative/pulsar/tree/v3.1.1.2/pulsar-io/aerospike"
license: Apache License 2.0
tags: ["Pulsar IO", "Aerospike", "Sink"]
alias: Aerospike Sink
features: ["Use Aerospike sink connector to sync data from Pulsar"]
license_link: "https://www.apache.org/licenses/LICENSE-2.0"
icon: "/images/connectors/aerospike-sink.png"
download: "https://github.com/streamnative/pulsar/releases/download/v3.1.1.1/pulsar-io-aerospike-3.1.1.1.nar"
download: "https://github.com/streamnative/pulsar/releases/download/v3.1.1.2/pulsar-io-aerospike-3.1.1.2.nar"
support: StreamNative
support_link: https://streamnative.io
support_img: "/images/streamnative.png"
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
---
description: support sink/source for AMQP version 1.0.0
author: gaoran10,Anonymitaet,dependabot[bot],freeznet
contributors: gaoran10,Anonymitaet,dependabot[bot],freeznet
author: gaoran10,Anonymitaet,dependabot[bot],shibd
contributors: gaoran10,Anonymitaet,dependabot[bot],shibd
language: Java,Shell,Dockerfile,Python
document:
source: https://github.com/streamnative/pulsar-io-amqp-1-0
Expand All @@ -11,7 +11,7 @@ tags:
alias: AMQP 1.0 Sink Connector
features: ["support sink/source for AMQP version 1.0.0"]
icon: "/images/connectors/amqp-logo.png"
download: https://api.github.com/repos/streamnative/pulsar-io-amqp-1-0/tarball/refs/tags/v3.1.1.1
download: https://api.github.com/repos/streamnative/pulsar-io-amqp-1-0/tarball/refs/tags/v3.1.1.2
support: streamnative
support_link: https://github.com/streamnative/pulsar-io-amqp-1-0
support_img: "https://avatars.githubusercontent.com/u/44651383?v=4"
Expand All @@ -27,7 +27,7 @@ id: "amqp-1-0-sink"

The AMQP 1.0 sink connector pulls messages from Pulsar topics and persists messages to [AMQP 1.0](https://www.amqp.org/).

![](https://raw.githubusercontent.com/streamnative/pulsar-io-amqp-1-0/v3.1.1.1/docs/amqp-1-0-sink.png)
![](https://raw.githubusercontent.com/streamnative/pulsar-io-amqp-1-0/v3.1.1.2/docs/amqp-1-0-sink.png)

## Quick start

Expand Down Expand Up @@ -143,18 +143,18 @@ Before using the AMQP 1.0 sink connector, you need to configure it.

You can create a configuration file (JSON or YAML) to set the following properties.

| Name | Type | Required | Default | Description |
|---------------------|------------|----------------------------------------------|---------------------|-----------------------------------------------------------------------------------------------------------------------------------------------|
| `protocol` | String | required if connection is not used | "amqp" | [deprecated: use connection instead] The AMQP protocol. |
| `host` | String | required if connection is not used | " " (empty string) | [deprecated: use connection instead] The AMQP service host. |
| `port` | int | required if connection is not used | 5672 | [deprecated: use connection instead] The AMQP service port. |
| `connection` | Connection | required if protocol, host, port is not used | " " (empty string) | The connection details. |
| `username` | String | false | " " (empty string) | The username used to authenticate to ActiveMQ. |
| `password` | String | false | " " (empty string) | The password used to authenticate to ActiveMQ. |
| `queue` | String | false | " " (empty string) | The queue name that messages should be read from or written to. |
| `topic` | String | false | " " (empty string) | The topic name that messages should be read from or written to. |
| `activeMessageType` | String | false | 0 | The ActiveMQ message simple class name. |
| `onlyTextMessage` | boolean | false | false | If it is set to `true`, the AMQP message type must be set to `TextMessage`. Pulsar consumers can consume the messages with schema ByteBuffer. |
| Name | Type | Required | Sensitive | Default | Description |
|---------------------|------------|----------------------------------------------|-----------|---------------------|-----------------------------------------------------------------------------------------------------------------------------------------------|
| `protocol` | String | required if connection is not used | false | "amqp" | [deprecated: use connection instead] The AMQP protocol. |
| `host` | String | required if connection is not used | false | " " (empty string) | [deprecated: use connection instead] The AMQP service host. |
| `port` | int | required if connection is not used | false | 5672 | [deprecated: use connection instead] The AMQP service port. |
| `connection` | Connection | required if protocol, host, port is not used | false | " " (empty string) | The connection details. |
| `username` | String | false | true | " " (empty string) | The username used to authenticate to ActiveMQ. |
| `password` | String | false | true | " " (empty string) | The password used to authenticate to ActiveMQ. |
| `queue` | String | false | false | " " (empty string) | The queue name that messages should be read from or written to. |
| `topic` | String | false | false | " " (empty string) | The topic name that messages should be read from or written to. |
| `activeMessageType` | String | false | false | 0 | The ActiveMQ message simple class name. |
| `onlyTextMessage` | boolean | false | false | false | If it is set to `true`, the AMQP message type must be set to `TextMessage`. Pulsar consumers can consume the messages with schema ByteBuffer. |

A `Connection` object can be specified as follows:

Expand Down
Loading

0 comments on commit 67095e2

Please sign in to comment.