diff --git a/docs/amqp-1-0-sink.md b/docs/amqp-1-0-sink.md index d09e1025..c57c5293 100644 --- a/docs/amqp-1-0-sink.md +++ b/docs/amqp-1-0-sink.md @@ -123,18 +123,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: diff --git a/docs/amqp-1-0-source.md b/docs/amqp-1-0-source.md index 1d844868..e934cf1b 100644 --- a/docs/amqp-1-0-source.md +++ b/docs/amqp-1-0-source.md @@ -109,18 +109,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: