| urls | []string | no | no | A list of URLs to connect to. The format should be scheme://host:port where scheme is one of tcp, ssl, or ws, host is the ip-address (or hostname) and port is the port on which the broker is accepting connections. If an item of the list contains commas it will be expanded into multiple URLs. |
| client_id | string | yes | no | An identifier for the client connection. If not provided a random client ID will be generated. The value defaults to ``. |
| dynamic_client_id_suffix | string | yes | no | Append a dynamically generated suffix to the specified client_id on each run of the pipeline. This can be useful when running multiple instances of this source. The value should be one of or nanoid. |
| connect_timeout | string | yes | no | The maximum amount of time to wait in order to establish a connection before the attempt is abandoned. The value defaults to 30s. |
| username | string | yes | no | The username to authenticate with the broker. The value defaults to ``. |
| password | string | yes | no | The password to authenticate with the broker. The value defaults to ``. |
| keepalive | int | no | no | The maximum amount of time in seconds that the client will wait before sending a PINGREQ message to the broker. The value defaults to 30. |
| will | will | yes | no | Set last will message in case of unexpected disconnection. |
| topics | []string | no | no | A list of topics to subscribe to. |
| qos | int | yes | no | The level of assurance for message delivery. The value should be one of 0, 1 or 2. The value defaults to 1. |
| clean_session | bool | yes | no | Set whether the connection is non-persistent. The value defaults to true. |
| auto_replay_nacks | bool | yes | no | Whether messages that are rejected (nacked) at the output level should be automatically replayed indefinitely, eventually resulting in back pressure if the cause of the rejections is persistent. If set to false these messages will instead be deleted. Disabling auto replays can greatly improve memory efficiency of high throughput streams as the original shape of the data can be discarded immediately upon consumption and mutation. The value defaults to true. |
