Connector Catalog

Use the following table to search for available inputs, outputs, and processors.

For a description of the support levels, see Connector Support Levels.

Connector Support Type

amqp_0_9

Certified

amqp_1

Community

archive

Certified

Processor

avro (Avro)

Community

Processor

awk (AWK)

Community

Processor

aws_dynamodb (AWS DynamoDB)

Community

Output

aws_kinesis (AWS Kinesis)

Certified

aws_kinesis_firehose (AWS Kinesis Firehose)

Certified

Output

aws_lambda (AWS Lambda)

Certified

Processor

aws_s3 (AWS S3)

Certified

aws_sns (AWS SNS)

Community

Output

aws_sqs (AWS SQS)

Certified

aws_dynamodb_partiql

Certified

Processor

azure_blob_storage (Azure Blob Storage)

Community

azure_cosmosdb (Azure Cosmos DB)

Community

azure_queue_storage (Azure Queue Storage)

Community

azure_table_storage (Azure Table Storage)

Community

batched

Community

Input

beanstalkd

Community

bloblang

Certified

Processor

bounds_check

Certified

Processor

branch

Community

Processor

broker

Community

cache
AWS DynamoDB

Certified

cache
AWS S3

Certified

cache
File

Certified

cache
Memcached

Certified

cache
Memory

Certified

cache
NATS KV

Certified

cache
Redis

Certified

cache
Ristretto

Certified

cache
Couchbase

Community

cache
MongoDB

Community

cache
SQL

Community

cache
Multilevel

Community

cache
TTL LRU

Community

cache
GCP Cloud Storage

Community

cache
LRU

Community

cache
Noop

Community

cached

Certified

Processor

cassandra (Cassandra)

Community

catch

Community

Processor

cockroachdb_changefeed (CockroachDB)

Community

Input

command

Community

Processor

compress

Certified

Processor

couchbase (Couchbase)

Community

Processor

csv (CSV)

Certified

Input

decompress

Certified

Processor

dedupe

Certified

Processor

discord (Discord)

Community

drop

Community

Output

drop_on

Community

Output

dynamic

Community

elasticsearch (Elasticsearch)

Community

Output

fallback

Community

Output

file

Community

for_each

Community

Processor

kafka_franz (Franz-go)

Certified

gcp_bigquery (GCP BigQuery)

Community

Output

gcp_cloud_storage (GCP Cloud Storage)

Community

gcp_pubsub (GCP Pub/Sub)

Community

gcp_bigquery_select

Community

generate

Certified

Input

grok (Grok)

Community

Processor

group_by

Certified

Processor

group_by_value

Certified

Processor

hdfs (HDFS)

Community

http (HTTP)

Certified

Processor

http_client

Certified

http_server

Community

inproc

Community

insert_part

Community

Processor

javascript (JavaScript)

Community

Processor

jmespath (JMESPath)

Certified

Processor

jq

Certified

Processor

json_schema (JSON Schema)

Certified

Processor

kafka (Kafka)

Certified

log

Certified

Processor

mapping

Certified

Processor

msgpack (MessagePack)

Community

Processor

metric

Certified

Processor

mongodb (MongoDB)

Community

mqtt (MQTT)

Community

mutation

Certified

Processor

nanomsg

Community

nats (NATS)

Certified

nats_jetstream

Certified

nats_kv

Certified

nats_request_reply

Certified

Processor

nats_stream

Community

noop

Community

Processor

nsq (NSQ)

Community

opensearch (OpenSearch)

Certified

Output

parallel

Community

Processor

parquet (Parquet)

Community

Input

parquet_decode

Certified

Processor

parquet_encode

Certified

Processor

parse_log

Community

Processor

processors

Community

Processor

protobuf (Protobuf)

Certified

Processor

pulsar (Pulsar)

Community

pusher

Community

Output

rate_limit

Certified

Processor

read_until

Community

Input

redis (Redis)

Certified

Processor

redis_hash

Certified

Output

redis_list

Certified

redis_pubsub

Certified

redis_scan

Community

Input

redis_script

Certified

Processor

redis_streams

Certified

reject

Community

Output

reject_errored

Community

Output

resource

Community

retry

Community

schema_registry_decode

Certified

Processor

schema_registry_encode

Certified

Processor

select_parts

Certified

Processor

sentry_capture

Community

Processor

sequence

Community

Input

sftp

Certified

sleep

Certified

Processor

snowflake_put (Snowflake)

Community

Output

socket (Socket)

Certified

socket_server

Certified

Input

split

Community

Processor

splunk

Community

Input

splunk_hec (Splunk)

Community

Output

sql_insert
MYSQL driver

Certified

sql_insert
PostgreSQL driver

Certified

sql_insert
ClickHouse driver

Community

sql_insert
Microsoft SQL Server driver

Community

sql_insert
SQLite driver

Certified

sql_insert
Oracle driver

Certified

sql_insert
Snowflake driver

Community

sql_insert
Trino driver

Community

sql_insert
Azure Cosmos DB driver

Community

sql_raw
MYSQL driver

Certified

sql_raw
PostgreSQL driver

Certified

sql_raw
ClickHouse driver

Community

sql_raw
Microsoft SQL Server driver

Community

sql_raw
SQLite driver

Certified

sql_raw
Oracle driver

Certified

sql_raw
Snowflake driver

Community

sql_raw
Trino driver

Community

sql_raw
Azure Cosmos DB driver

Community

sql_select
MYSQL driver

Certified

sql_select
PostgreSQL driver

Certified

sql_select
ClickHouse driver

Community

sql_select
Microsoft SQL Server driver

Community

sql_select
SQLite driver

Certified

sql_select
Oracle driver

Certified

sql_select
Snowflake driver

Community

sql_select
Trino driver

Community

sql_select
Azure Cosmos DB driver

Community

stdin

Community

Input

stdout

Community

Output

subprocess

Community

switch

Community

sync_response

Community

try

Community

Processor

unarchive

Certified

Processor

wasm (WebAssembly)

Community

Processor

websocket (WebSocket)

Certified

while

Community

Processor

workflow

Certified

Processor

twitter_search (X/Twitter)

Community

Input

xml (XML)

Community

Processor

zmq4

Community