# Outputs

> For the complete documentation index, see [llms.txt](https://docs.redpanda.com/llms.txt). Component-specific: [connect-full.txt](https://docs.redpanda.com/connect-full.txt)

---
title: Outputs
latest-connect-version: 4.93.0
latest-operator-version: v26.1.4
latest-console-tag: v3.7.3
latest-redpanda-tag: v26.1.9
docname: outputs/about
page-component-name: connect
page-version: master
page-component-version: master
page-component-title: Connect
page-relative-src-path: outputs/about.adoc
page-edit-url: https://github.com/redpanda-data/rp-connect-docs/edit/main/modules/components/pages/outputs/about.adoc
page-git-created-date: "2024-05-24"
page-git-modified-date: "2024-09-05"
---

<!-- Source: https://docs.redpanda.com/connect/components/outputs/about.md -->

An output is a sink where we wish to send our consumed data after applying an optional array of [processors](https://docs.redpanda.com/connect/components/processors/about/). Only one output is configured at the root of a Redpanda Connect config. However, the output can be a [broker](https://docs.redpanda.com/connect/components/outputs/broker/) which combines multiple outputs under a chosen brokering pattern, or a [switch](https://docs.redpanda.com/connect/components/outputs/switch/) which is used to multiplex against different outputs.

An output config section looks like this:

```yaml
output:
  label: my_s3_output

  aws_s3:
    bucket: TODO
    path: '${! meta("kafka_topic") }/${! json("message.id") }.json'

  # Optional list of processing steps
  processors:
    - mapping: '{"message":this,"meta":{"link_count":this.links.length()}}'
```

## [](#back-pressure)Back pressure

Redpanda Connect outputs apply back pressure to components upstream. This means if your output target starts blocking traffic Redpanda Connect will gracefully stop consuming until the issue is resolved.

## [](#retries)Retries

When a Redpanda Connect output fails to send a message the error is propagated back up to the input, where depending on the protocol it will either be pushed back to the source as a Noack (e.g. AMQP) or will be reattempted indefinitely with the commit withheld until success (e.g. Kafka).

It’s possible to instead have Redpanda Connect indefinitely retry an output until success with a [`retry`](https://docs.redpanda.com/connect/components/outputs/retry/) output. Some other outputs, such as the [`broker`](https://docs.redpanda.com/connect/components/outputs/broker/), might also retry indefinitely depending on their configuration.

## [](#dead-letter-queues)Dead letter queues

It’s possible to create fallback outputs for when an output target fails using a [`fallback`](https://docs.redpanda.com/connect/components/outputs/fallback/) output:

```yaml
output:
  fallback:
    - aws_sqs:
        url: https://sqs.us-west-2.amazonaws.com/TODO/TODO
        max_in_flight: 20

    - http_client:
        url: http://backup:1234/dlq
        verb: POST
```

## [](#multiplexing-outputs)Multiplexing outputs

There are a few different ways of multiplexing in Redpanda Connect, here’s a quick run through:

### [](#interpolation-multiplexing)Interpolation multiplexing

Some output fields support [field interpolation](https://docs.redpanda.com/connect/configuration/interpolation/), which is a super easy way to multiplex messages based on their contents in situations where you are multiplexing to the same service.

For example, multiplexing against Kafka topics is a common pattern:

```yaml
output:
  kafka:
    addresses: [ TODO:6379 ]
    topic: ${! meta("target_topic") }
```

Refer to the field documentation for a given output to see if it support interpolation.

### [](#switch-multiplexing)Switch multiplexing

A more advanced form of multiplexing is to route messages to different output configurations based on a query. This is easy with the [`switch` output](https://docs.redpanda.com/connect/components/outputs/switch/):

```yaml
output:
  switch:
    cases:
      - check: this.type == "foo"
        output:
          amqp_1:
            urls: [ amqps://guest:guest@localhost:5672/ ]
            target_address: queue:/the_foos

      - check: this.type == "bar"
        output:
          gcp_pubsub:
            project: dealing_with_mike
            topic: mikes_bars

      - output:
          redis_streams:
            url: tcp://localhost:6379
            stream: everything_else
          processors:
            - mapping: |
                root = this
                root.type = this.type.not_null() | "unknown"
```

## [](#labels)Labels

Outputs have an optional field `label` that can uniquely identify them in observability data such as metrics and logs. This can be useful when running configs with multiple outputs, otherwise their metrics labels will be generated based on their composition. For more information check out the [metrics documentation](https://docs.redpanda.com/connect/components/metrics/about/).

## [](#categories)Categories

### Services

Outputs that write to storage or message streaming services.

[**RabbitMQ**](https://docs.redpanda.com/connect/components/outputs/amqp_0_9/) [**RabbitMQ**](https://docs.redpanda.com/connect/components/outputs/amqp_1/) [**Arc**](https://docs.redpanda.com/connect/components/outputs/arc/) [**AWS DynamoDB**](https://docs.redpanda.com/connect/components/outputs/aws_dynamodb/) [**AWS Kinesis**](https://docs.redpanda.com/connect/components/outputs/aws_kinesis/) [**AWS Kinesis Firehose**](https://docs.redpanda.com/connect/components/outputs/aws_kinesis_firehose/) [**AWS S3**](https://docs.redpanda.com/connect/components/outputs/aws_s3/) [**AWS SNS**](https://docs.redpanda.com/connect/components/outputs/aws_sns/) [**AWS SQS**](https://docs.redpanda.com/connect/components/outputs/aws_sqs/) [**Azure Blob Storage**](https://docs.redpanda.com/connect/components/outputs/azure_blob_storage/) [**Microsoft Azure**](https://docs.redpanda.com/connect/components/outputs/azure_data_lake_gen2/) [**Azure Queue Storage**](https://docs.redpanda.com/connect/components/outputs/azure_queue_storage/) [**Azure Table Storage**](https://docs.redpanda.com/connect/components/outputs/azure_table_storage/) [**beanstalkd**](https://docs.redpanda.com/connect/components/outputs/beanstalkd/) [**cache**](https://docs.redpanda.com/connect/components/outputs/cache/) [**cypher**](https://docs.redpanda.com/connect/components/outputs/cypher/) [**discord**](https://docs.redpanda.com/connect/components/outputs/discord/) [**elasticsearch\_v8**](https://docs.redpanda.com/connect/components/outputs/elasticsearch_v8/) [**elasticsearch\_v9**](https://docs.redpanda.com/connect/components/outputs/elasticsearch_v9/) [**GCP BigQuery**](https://docs.redpanda.com/connect/components/outputs/gcp_bigquery/) [**GCP BigQuery**](https://docs.redpanda.com/connect/components/outputs/gcp_bigquery_write_api/) [**GCP Cloud Storage**](https://docs.redpanda.com/connect/components/outputs/gcp_cloud_storage/) [**GCP PubSub**](https://docs.redpanda.com/connect/components/outputs/gcp_pubsub/) [**hdfs**](https://docs.redpanda.com/connect/components/outputs/hdfs/) [**Apache Iceberg**](https://docs.redpanda.com/connect/components/outputs/iceberg/) [**MongoDB**](https://docs.redpanda.com/connect/components/outputs/mongodb/) [**mqtt**](https://docs.redpanda.com/connect/components/outputs/mqtt/) [**NATS**](https://docs.redpanda.com/connect/components/outputs/nats/) [**NATS JetStream**](https://docs.redpanda.com/connect/components/outputs/nats_jetstream/) [**NATS KV**](https://docs.redpanda.com/connect/components/outputs/nats_kv/) [**NATS Stream**](https://docs.redpanda.com/connect/components/outputs/nats_stream/) [**nsq**](https://docs.redpanda.com/connect/components/outputs/nsq/) [**ockam\_kafka**](https://docs.redpanda.com/connect/components/outputs/ockam_kafka/) [**opensearch**](https://docs.redpanda.com/connect/components/outputs/opensearch/) [**OpenTelemetry**](https://docs.redpanda.com/connect/components/outputs/otlp_grpc/) [**OpenTelemetry**](https://docs.redpanda.com/connect/components/outputs/otlp_http/) [**Apache Pulsar**](https://docs.redpanda.com/connect/components/outputs/pulsar/) [**pusher**](https://docs.redpanda.com/connect/components/outputs/pusher/) [**questdb**](https://docs.redpanda.com/connect/components/outputs/questdb/) [**Redis Hash**](https://docs.redpanda.com/connect/components/outputs/redis_hash/) [**Redis List**](https://docs.redpanda.com/connect/components/outputs/redis_list/) [**Redis PubSub**](https://docs.redpanda.com/connect/components/outputs/redis_pubsub/) [**Redis Streams**](https://docs.redpanda.com/connect/components/outputs/redis_streams/) [**redpanda**](https://docs.redpanda.com/connect/components/outputs/redpanda/) [**redpanda\_common**](https://docs.redpanda.com/connect/components/outputs/redpanda_common/) [**redpanda\_migrator**](https://docs.redpanda.com/connect/components/outputs/redpanda_migrator/) [**Salesforce**](https://docs.redpanda.com/connect/components/outputs/salesforce_sink/) [**Snowflake**](https://docs.redpanda.com/connect/components/outputs/snowflake_put/) [**Snowflake Streaming**](https://docs.redpanda.com/connect/components/outputs/snowflake_streaming/) [**Splunk**](https://docs.redpanda.com/connect/components/outputs/splunk_hec/) [**SQL**](https://docs.redpanda.com/connect/components/outputs/sql_insert/) [**SQL**](https://docs.redpanda.com/connect/components/outputs/sql_raw/) [**timeplus**](https://docs.redpanda.com/connect/components/outputs/timeplus/)

### AWS

Outputs that write to Amazon Web Services products.

[**AWS DynamoDB**](https://docs.redpanda.com/connect/components/outputs/aws_dynamodb/) [**AWS Kinesis**](https://docs.redpanda.com/connect/components/outputs/aws_kinesis/) [**AWS Kinesis Firehose**](https://docs.redpanda.com/connect/components/outputs/aws_kinesis_firehose/) [**AWS S3**](https://docs.redpanda.com/connect/components/outputs/aws_s3/) [**AWS SNS**](https://docs.redpanda.com/connect/components/outputs/aws_sns/) [**AWS SQS**](https://docs.redpanda.com/connect/components/outputs/aws_sqs/) [**Apache Iceberg**](https://docs.redpanda.com/connect/components/outputs/iceberg/)

### Azure

Outputs that write to Microsoft Azure services.

[**Azure Blob Storage**](https://docs.redpanda.com/connect/components/outputs/azure_blob_storage/) [**Microsoft Azure**](https://docs.redpanda.com/connect/components/outputs/azure_cosmosdb/) [**Microsoft Azure**](https://docs.redpanda.com/connect/components/outputs/azure_data_lake_gen2/) [**Azure Queue Storage**](https://docs.redpanda.com/connect/components/outputs/azure_queue_storage/) [**Azure Table Storage**](https://docs.redpanda.com/connect/components/outputs/azure_table_storage/) [**Apache Iceberg**](https://docs.redpanda.com/connect/components/outputs/iceberg/)

### Utility

Outputs that provide utility by combining/wrapping other outputs.

[**broker**](https://docs.redpanda.com/connect/components/outputs/broker/) [**drop**](https://docs.redpanda.com/connect/components/outputs/drop/) [**drop\_on**](https://docs.redpanda.com/connect/components/outputs/drop_on/) [**dynamic**](https://docs.redpanda.com/connect/components/outputs/dynamic/) [**fallback**](https://docs.redpanda.com/connect/components/outputs/fallback/) [**inproc**](https://docs.redpanda.com/connect/components/outputs/inproc/) [**reject**](https://docs.redpanda.com/connect/components/outputs/reject/) [**reject\_errored**](https://docs.redpanda.com/connect/components/outputs/reject_errored/) [**resource**](https://docs.redpanda.com/connect/components/outputs/resource/) [**retry**](https://docs.redpanda.com/connect/components/outputs/retry/) [**subprocess**](https://docs.redpanda.com/connect/components/outputs/subprocess/) [**switch**](https://docs.redpanda.com/connect/components/outputs/switch/) [**sync\_response**](https://docs.redpanda.com/connect/components/outputs/sync_response/)

### Integration

[**couchbase**](https://docs.redpanda.com/connect/components/outputs/couchbase/) [**schema\_registry**](https://docs.redpanda.com/connect/components/outputs/schema_registry/)

### AI

[**cyborgdb**](https://docs.redpanda.com/connect/components/outputs/cyborgdb/) [**pinecone**](https://docs.redpanda.com/connect/components/outputs/pinecone/) [**qdrant**](https://docs.redpanda.com/connect/components/outputs/qdrant/)

### Social

Outputs that write to social applications and services.

[**discord**](https://docs.redpanda.com/connect/components/outputs/discord/)

### Local

Outputs that write to the local machine/filesystem.

[**file**](https://docs.redpanda.com/connect/components/outputs/file/) [**stdout**](https://docs.redpanda.com/connect/components/outputs/stdout/)

### GCP

Outputs that write to Google Cloud Platform services.

[**GCP BigQuery**](https://docs.redpanda.com/connect/components/outputs/gcp_bigquery/) [**GCP BigQuery**](https://docs.redpanda.com/connect/components/outputs/gcp_bigquery_write_api/) [**GCP Cloud Storage**](https://docs.redpanda.com/connect/components/outputs/gcp_cloud_storage/) [**GCP PubSub**](https://docs.redpanda.com/connect/components/outputs/gcp_pubsub/) [**Apache Iceberg**](https://docs.redpanda.com/connect/components/outputs/iceberg/)

### Network

Outputs that write directly to low level network protocols.

[**HTTP**](https://docs.redpanda.com/connect/components/outputs/http_client/) [**HTTP**](https://docs.redpanda.com/connect/components/outputs/http_server/) [**nanomsg**](https://docs.redpanda.com/connect/components/outputs/nanomsg/) [**sftp**](https://docs.redpanda.com/connect/components/outputs/sftp/) [**socket**](https://docs.redpanda.com/connect/components/outputs/socket/) [**websocket**](https://docs.redpanda.com/connect/components/outputs/websocket/) [**zmq4**](https://docs.redpanda.com/connect/components/outputs/zmq4/)

###

[**Slack Reaction**](https://docs.redpanda.com/connect/components/outputs/slack_reaction/)