Connect plugin: outputs

The 68 Redpanda Connect outputs the Connect plugin links, generated from the component specs of Redpanda Connect v4.110.0. Field descriptions are Redpanda Connect’s own, shortened to one sentence; follow Upstream documentation for the rest. Install and configuration forms are on the plugin page.

Use one as a route output:

output:
  custom:
    name: connect
    config:
      connector: mqtt          # the component name below
      urls: ["tcp://localhost:1883"]
      topic: "orders"

Category	Components
AI	`cyborgdb`, `pinecone`, `qdrant`
AWS	`aws_kinesis`, `aws_kinesis_firehose`, `aws_s3`, `aws_sns`, `aws_sqs`
Azure	`azure_blob_storage`, `azure_cosmosdb`, `azure_data_lake_gen2`, `azure_queue_storage`, `azure_table_storage`
GCP	`gcp_bigquery`, `gcp_cloud_storage`, `gcp_pubsub`
Integration	`couchbase`
Local	`file`, `stdout`
Network	`http_client`, `http_server`, `nanomsg`, `sftp`, `socket`, `websocket`
Other	`cassandra`
Services	`amqp_0_9`, `amqp_1`, `arc`, `aws_kinesis`, `aws_kinesis_firehose`, `aws_s3`, `aws_sns`, `aws_sqs`, `azure_blob_storage`, `azure_data_lake_gen2`, `azure_queue_storage`, `azure_table_storage`, `beanstalkd`, `cache`, `cypher`, `discord`, `doris_stream_load`, `elasticsearch_v8`, `elasticsearch_v9`, `gcp_bigquery`, `gcp_cloud_storage`, `gcp_pubsub`, `hdfs`, `mongodb`, `mqtt`, `nats`, `nats_jetstream`, `nats_kv`, `nats_stream`, `nsq`, `opensearch`, `pulsar`, `pusher`, `questdb`, `redis_hash`, `redis_list`, `redis_pubsub`, `redis_streams`, `sql`, `sql_insert`, `sql_raw`
Social	`discord`
Utility	`broker`, `drop`, `drop_on`, `dynamic`, `fallback`, `inproc`, `reject`, `reject_errored`, `resource`, `retry`, `subprocess`, `switch`, `sync_response`

`amqp_0_9`

Sends messages to an AMQP (0.91) exchange. AMQP is a messaging protocol used by various message brokers, including RabbitMQ.

connector: amqp_0_9 · URI connect+amqp-0-9://

Field	Type	Default	Description
`urls`	list of string	required	A list of URLs to connect to.
`exchange`	string	required	An AMQP exchange to publish to.
`key`	string	`""`	The binding key to set for each message.
`type`	string	`""`	The type property to set for each message.
`metadata`	object		Specify criteria for which metadata values are attached to messages as headers.
`max_in_flight`	int	`64`	The maximum number of messages to have in flight at a given time.

Advanced: exchange_declare, content_type, content_encoding, correlation_id, reply_to, expiration, message_id, user_id, app_id, priority, persistent, mandatory, immediate, timeout, tls.

Field	Type	Default	Description
`base_url`	string	required	Base URL of the target service (e.g., https://api.example.com).
`timeout`	string	`"5s"`	HTTP request timeout.
`token`	string		Bearer token for authentication.
`database`	string	`"default"`	The target database name.
`measurement`	string	required	The measurement (table) name.
`format`	string	`"columnar"`	The payload format.
`tags_mapping`	string		An optional Bloblang mapping to extract tags from each message.
`compression`	string	`"zstd"`	Compression algorithm for the request body.
`max_in_flight`	int	`64`	The maximum number of messages to have in flight at a given time.
`batching`	object		Allows you to configure a batching policy.

Field	Type	Default	Description
`endpoint`	string		CosmosDB endpoint.
`account_key`	string		Account key.
`connection_string`	string		Connection string.
`database`	string	required	Database.
`container`	string	required	Container.
`partition_keys_map`	string	required	A Bloblang mapping which should evaluate to a single partition key value or an array of partition key values of type string, integer or boolean.
`operation`	string	`"Create"`	Operation.
`item_id`	string		ID of item to replace or delete.
`batching`	object		Allows you to configure a batching policy.
`max_in_flight`	int	`64`	The maximum number of messages to have in flight at a given time.

Field	Type	Default	Description
`storage_account`	string	`""`	The storage account to access.
`storage_access_key`	string	`""`	The storage account access key.
`storage_connection_string`	string	`""`	A storage account connection string.
`storage_sas_token`	string	`""`	The storage account SAS token.
`queue_name`	string	required	The name of the target Queue Storage queue.
`max_in_flight`	int	`64`	The maximum number of parallel message batches to have in flight at any given time.
`batching`	object		Allows you to configure a batching policy.

Field	Type	Default	Description
`storage_account`	string	`""`	The storage account to access.
`storage_access_key`	string	`""`	The storage account access key.
`storage_connection_string`	string	`""`	A storage account connection string.
`storage_sas_token`	string	`""`	The storage account SAS token.
`table_name`	string	required	The table to store messages into.
`partition_key`	string	`""`	The partition key.
`row_key`	string	`""`	The row key.
`properties`	map of string	`{}`	A map of properties to store into the table.
`max_in_flight`	int	`64`	The maximum number of parallel message batches to have in flight at any given time.
`batching`	object		Allows you to configure a batching policy.

Keyboard shortcuts

mq-bridge