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.


Name Connector Type Support Level Enterprise Licensed

amqp_0_9

Input, Output

Certified

No

amqp_1

Input, Output

Community

No

archive

Processor

Certified

No

avro

Processor, Scanner

Community

No

awk

Processor

Community

No

aws_bedrock_chat

Processor

Certified

Yes

aws_bedrock_embeddings

Processor

Certified

Yes

aws_cloudwatch

Metric

Community

No

aws_dynamodb

Cache, Output

Community

No

aws_dynamodb_partiql

Processor

Certified

No

aws_kinesis

Input, Output

Certified

No

aws_kinesis_firehose

Output

Certified

No

aws_lambda

Processor

Certified

No

aws_s3

Cache, Input, Output

Certified

No

aws_sns

Output

Community

No

aws_sqs

Input, Output

Certified

No

azure_blob_storage

Input, Output

Certified

No

azure_cosmosdb

Input, Output, Processor

Certified

No

azure_data_lake_gen2

Output

Certified

No

azure_queue_storage

Input, Output

Certified

No

azure_table_storage

Input, Output

Certified

No

batched

Input

Certified

No

beanstalkd

Input, Output

Community

No

bloblang

Processor

Certified

No

bounds_check

Processor

Certified

No

branch

Processor

Certified

No

broker

Input, Output

Certified

No

cache

Output, Processor

Certified

No

cached

Processor

Certified

No

cassandra

Input, Output

Community

No

catch

Processor

Certified

No

chunker

Scanner

Certified

No

cockroachdb_changefeed

Input

Community

No

cohere_chat

Processor

Certified

Yes

cohere_embeddings

Processor

Certified

Yes

command

Processor

Certified

No

compress

Processor

Certified

No

couchbase

Cache, Output, Processor

Community

No

csv

Input, Scanner

Certified

No

cypher

Output

Community

No

decompress

Processor, Scanner

Certified

No

dedupe

Processor

Certified

No

discord

Input, Output

Community

No

drop

Output

Certified

No

drop_on

Output

Certified

No

dynamic

Input, Output

Community

No

elasticsearch

Output

Community

No

fallback

Output

Certified

No

file

Cache, Input, Output

Certified

No

for_each

Processor

Certified

No

gcp_bigquery

Output

Certified

No

gcp_bigquery_select

Input, Processor

Certified

No

gcp_cloud_storage

Cache, Input, Output

Certified

No

gcp_cloudtrace

Tracer

Certified

No

gcp_pubsub

Input, Output

Certified

No

gcp_vertex_ai_chat

Processor

Certified

Yes

gcp_vertex_ai_embeddings

Processor

Certified

Yes

generate

Input

Certified

No

grok

Processor

Community

No

group_by

Processor

Certified

No

group_by_value

Processor

Certified

No

hdfs

Input, Output

Community

No

http

Processor

Certified

No

http_client

Input, Output

Certified

No

http_server

Input, Output

Certified

No

influxdb

Metric

Community

No

inproc

Input, Output

Certified

No

insert_part

Processor

Certified

No

jaeger

Tracer

Community

No

javascript

Processor

Certified

No

jmespath

Processor

Certified

No

jq

Processor

Certified

No

json_api

Metric

Certified

No

json_documents

Scanner

Certified

No

json_schema

Processor

Certified

No

kafka

Input, Output

Certified

No

kafka_franz

Input, Output

Certified

No

lines

Scanner

Certified

No

local

Rate_limit

Certified

No

log

Processor

Certified

No

logger

Metric

Certified

No

lru

Cache

Community

No

mapping

Processor

Certified

No

memcached

Cache

Community

No

memory

Buffer, Cache

Certified

No

metric

Processor

Certified

No

mongodb

Cache, Input, Output, Processor

Community

No

mqtt

Input, Output

Certified

No

msgpack

Processor

Community

No

multilevel

Cache

Certified

No

mutation

Processor

Certified

No

nanomsg

Input, Output

Community

No

nats

Input, Output

Certified

No

nats_jetstream

Input, Output

Certified

No

nats_kv

Cache, Input, Output, Processor

Certified

No

nats_request_reply

Processor

Certified

No

nats_stream

Input, Output

Community

No

none

Buffer, Metric, Tracer

Certified

No

noop

Cache, Processor

Certified

No

nsq

Input, Output

Community

No

ockam_kafka

Community

No

ollama_chat

Processor

Certified

Yes

ollama_embeddings

Processor

Certified

Yes

open_telemetry_collector

Tracer

Community

No

openai_chat_completion

Processor

Certified

Yes

openai_embeddings

Processor

Certified

Yes

openai_image_generation

Processor

Certified

Yes

openai_speech

Processor

Certified

Yes

openai_transcription

Processor

Certified

Yes

openai_translation

Processor

Certified

Yes

opensearch

Output

Certified

No

parallel

Processor

Certified

No

parquet

Input, Processor

Certified: input

Community: processor

No

parquet_decode

Processor

Certified

No

parquet_encode

Processor

Certified

No

parse_log

Processor

Community

No

pg_stream

Community

No

pinecone

Output

Certified

No

processors

Processor

Certified

No

prometheus

Metric

Certified

No

protobuf

Processor

Certified

No

pulsar

Input, Output

Community

No

pusher

Output

Community

No

qdrant

Output

Certified

No

questdb

Output

Certified

No

rate_limit

Processor

Certified

No

re_match

Scanner

Certified

No

read_until

Input

Certified

No

redis

Cache, Processor, Rate_limit

Certified

No

redis_hash

Output

Certified

No

redis_list

Input, Output

Certified

No

redis_pubsub

Input, Output

Certified

No

redis_scan

Input

Certified

No

redis_script

Processor

Certified

No

redis_streams

Input, Output

Certified

No

redpanda

Input, Output

Certified

No

redpanda_common

Input, Output

Certified

Yes

redpanda_data_transform

Processor

Certified

No

redpanda_migrator

Input, Output

Certified

Yes

redpanda_migrator_bundle

Input, Output

Certified

Yes

redpanda_migrator_offsets

Output

Certified

Yes

reject

Output

Certified

No

reject_errored

Output

Certified

No

resource

Input, Output, Processor

Certified

No

retry

Output, Processor

Certified

No

ristretto

Cache

Community

No

schema_registry

Input, Output

Certified

Yes

schema_registry_decode

Processor

Certified

No

schema_registry_encode

Processor

Certified

No

select_parts

Processor

Certified

No

sentry_capture

Processor

Community

No

sequence

Input

Certified

No

sftp

Input, Output

Certified

No

skip_bom

Scanner

Certified

No

sleep

Processor

Certified

No

snowflake_put

Output

Certified

Yes

snowflake_streaming

Output

Certified

Yes

socket

Input, Output

Certified

No

socket_server

Input

Certified

No

spicedb_watch

Input

Community

No

split

Processor

Certified

No

splunk

Input

Certified

Yes

splunk_hec

Output

Certified

Yes

sql

Cache, Output, Processor

Certified: cache

Community: output, processor

No

sql_driver_clickhouse

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sql_driver_gocosmos

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sql_driver_mssql

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sql_driver_mysql

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sql_driver_oracle

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sql_driver_postgres

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sql_driver_snowflake

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sql_driver_sqlite

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sql_driver_trino

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sql_insert

Output, Processor

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sql_raw

Input, Output, Processor

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sql_select

Input, Processor

Certified: MYSQL, Oracle, PostgreSQL, SQLite
Community: ClickHouse, Azure Cosmos DB, Microsoft SQL Server, Snowflake, Trino

No

sqlite

Buffer

Community

No

statsd

Metric

Certified

No

stdin

Input

Certified

No

stdout

Output

Certified

No

subprocess

Input, Output, Processor

Community

No

switch

Output, Processor, Scanner

Certified

No

sync_response

Output, Processor

Certified

No

system_window

Buffer

Certified

No

tar

Scanner

Certified

No

timeplus

Input, Output

Community

No

to_the_end

Scanner

Certified

No

try

Processor

Certified

No

ttlru

Cache

Community

No

twitter_search

Input

Community

No

unarchive

Processor

Certified

No

wasm

Processor

Community

No

websocket

Input, Output

Certified

No

while

Processor

Certified

No

workflow

Processor

Certified

No

xml

Processor

Community

No

zmq4

Input, Output

Community

No