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 |
Certified |
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 |
Certified |
|
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 |
Certified |
|
inproc |
Community |
|
insert_part |
Community |
Processor |
javascript (JavaScript) |
Certified |
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 |
Enterprise snowflake_put (Snowflake) |
Certified |
Output |
socket (Socket) |
Certified |
|
socket_server |
Certified |
Input |
split |
Community |
Processor |
splunk |
Community |
Input |
Enterprise splunk_hec (Splunk) |
Certified |
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 |
