Connector Catalog

Connectors listed in this catalog are available to use and fully supported in Redpanda Cloud. All other Redpanda Connect connectors are currently blocked.

Search for connectors for your use case.

Name Connector Type

amqp_0_9

Input, Output

archive

Processor

avro

Processor, Scanner

aws_bedrock_chat

Processor

aws_bedrock_embeddings

Processor

aws_dynamodb

Cache, Output

aws_dynamodb_partiql

Processor

aws_kinesis

Input, Output

aws_kinesis_firehose

Output

aws_lambda

Processor

aws_s3

Cache, Input, Output

aws_sns

Output

aws_sqs

Input, Output

azure_blob_storage

Input, Output

azure_cosmosdb

Input, Output, Processor

azure_data_lake_gen2

Output

azure_queue_storage

Input, Output

azure_table_storage

Input, Output

batched

Input

benchmark

Processor

bloblang

Processor

bounds_check

Processor

branch

Processor

broker

Input, Output

cache

Output, Processor

cached

Processor

catch

Processor

chunker

Scanner

cohere_chat

Processor

cohere_embeddings

Processor

compress

Processor

csv

Scanner

decompress

Processor, Scanner

dedupe

Processor

drop

Output

drop_on

Output

fallback

Output

for_each

Processor

gcp_bigquery

Output

gcp_bigquery_select

Input, Processor

gcp_cloud_storage

Cache, Input, Output

gcp_cloudtrace

Tracer

gcp_pubsub

Input, Output

gcp_vertex_ai_chat

Processor

gcp_vertex_ai_embeddings

Processor

generate

Input

group_by

Processor

group_by_value

Processor

http

http_client

inproc

Input, Output

insert_part

Processor

jmespath

Processor

jq

Processor

json_documents

Scanner

json_schema

Processor

kafka

Input, Output

kafka_franz

Input, Output

lines

Scanner

local

Rate_limit

log

Processor

lru

Cache

mapping

Processor

memcached

Cache

memory

Buffer, Cache

metric

Processor

mqtt

Input, Output

multilevel

Cache

mutation

Processor

nats

Input, Output

nats_jetstream

Input, Output

nats_kv

Cache, Input, Output, Processor

nats_request_reply

Processor

none

Buffer, Metric, Tracer

noop

Cache, Processor

openai_chat_completion

Processor

openai_embeddings

Processor

openai_image_generation

Processor

openai_speech

Processor

openai_transcription

Processor

openai_translation

Processor

opensearch

Output

parallel

Processor

parquet_decode

Processor

parquet_encode

Processor

parse_log

Processor

pg_stream

pinecone

Output

postgres_cdc

Input

processors

Processor

prometheus

Metric

protobuf

Processor

qdrant

Output

questdb

Output

rate_limit

Processor

re_match

Scanner

read_until

Input

redis

Cache, Processor, Rate_limit

redis_hash

Output

redis_list

Input, Output

redis_pubsub

Input, Output

redis_scan

Input

redis_script

Processor

redis_streams

Input, Output

redpanda

Input, Output

redpanda_common

redpanda_migrator

Input, Output

redpanda_migrator_bundle

Input, Output

redpanda_migrator_offsets

Output

reject

Output

reject_errored

Output

resource

Input, Output, Processor

retry

Output, Processor

ristretto

Cache

schema_registry

Input, Output

schema_registry_decode

Processor

schema_registry_encode

Processor

select_parts

Processor

sequence

Input

sftp

Input, Output

skip_bom

Scanner

sleep

Processor

snowflake_put

Output

snowflake_streaming

Output

spicedb_watch

Input

split

Processor

splunk

Input

splunk_hec

Output

sql_driver_mysql

sql_driver_oracle

sql_driver_postgres

sql_driver_sqlite

sql_insert

Output, Processor

sql_raw

Input, Output, Processor

sql_select

Input, Processor

switch

Output, Processor, Scanner

sync_response

Output, Processor

system_window

Buffer

tar

Scanner

timeplus

Input, Output

to_the_end

Scanner

try

Processor

ttlru

Cache

unarchive

Processor

while

Processor

workflow

Processor

xml

Processor