Docs Connect Components Connector Catalog 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. All SupportCertifiedCommunity All TypesInputOutputProcessor Connector Support Type amqp_0_9 Certified InputOutput amqp_1 Community InputOutput archive Certified Processor avro (Avro) Community Processor awk (AWK) Community Processor aws_dynamodb (AWS DynamoDB) Community Output aws_kinesis (AWS Kinesis) Certified InputOutput aws_kinesis_firehose (AWS Kinesis Firehose) Certified Output aws_lambda (AWS Lambda) Certified Processor aws_s3 (AWS S3) Certified InputOutput aws_sns (AWS SNS) Community Output aws_sqs (AWS SQS) Certified InputOutput Enterpriseaws_bedrock_chat Certified Processor aws_dynamodb_partiql Certified Processor azure_blob_storage (Azure Blob Storage) Community InputOutput azure_cosmosdb (Azure Cosmos DB) Community InputOutputProcessor azure_queue_storage (Azure Queue Storage) Community InputOutput azure_table_storage (Azure Table Storage) Community InputOutput batched Community Input beanstalkd Community InputOutput bloblang Certified Processor bounds_check Certified Processor branch Community Processor broker Community InputOutput cache AWS DynamoDB Certified OutputProcessor cache AWS S3 Certified OutputProcessor cache File Certified OutputProcessor cache Memcached Certified OutputProcessor cache Memory Certified OutputProcessor cache NATS KV Certified OutputProcessor cache Redis Certified OutputProcessor cache Ristretto Certified OutputProcessor cache Couchbase Community OutputProcessor cache MongoDB Community OutputProcessor cache SQL Community OutputProcessor cache Multilevel Community OutputProcessor cache TTL LRU Community OutputProcessor cache GCP Cloud Storage Community OutputProcessor cache LRU Community OutputProcessor cache Noop Community OutputProcessor cached Certified Processor cassandra (Cassandra) Community InputOutput 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 InputOutput drop Community Output drop_on Community Output dynamic Community InputOutput elasticsearch (Elasticsearch) Community Output fallback Community Output file Certified InputOutput for_each Community Processor kafka_franz (Franz-go) Certified InputOutput gcp_bigquery (GCP BigQuery) Community Output gcp_cloud_storage (GCP Cloud Storage) Community InputOutput gcp_pubsub (GCP Pub/Sub) Community InputOutput gcp_bigquery_select Community InputProcessor Enterprisegcp_vertex_ai_chat Certified Processor generate Certified Input grok (Grok) Community Processor group_by Certified Processor group_by_value Certified Processor hdfs (HDFS) Community InputOutput http (HTTP) Certified Processor http_client Certified InputOutput http_server Certified InputOutput inproc Community InputOutput insert_part Community Processor javascript (JavaScript) Certified Processor jmespath (JMESPath) Certified Processor jq Certified Processor json_schema (JSON Schema) Certified Processor kafka (Kafka) Certified InputOutput log Certified Processor mapping Certified Processor msgpack (MessagePack) Community Processor metric Certified Processor mongodb (MongoDB) Community InputOutputProcessor mqtt (MQTT) Community InputOutput mutation Certified Processor nanomsg Community InputOutput nats (NATS) Certified InputOutput nats_jetstream Certified InputOutput nats_kv Certified InputOutputProcessor nats_request_reply Certified Processor nats_stream Community InputOutput noop Community Processor nsq (NSQ) Community InputOutput Enterpriseollama_chat Certified Processor Enterpriseollama_embeddings Certified Processor Enterpriseopenai_chat_completion Certified Processor Enterpriseopenai_embeddings Certified Processor Enterpriseopenai_image_generation Certified Processor Enterpriseopenai_speech Certified Processor Enterpriseopenai_transcription Certified Processor Enterpriseopenai_translation Certified Processor opensearch (OpenSearch) Certified Output parallel Community Processor parquet (Parquet) Community Input parquet_decode Certified Processor parquet_encode Certified Processor parse_log Community Processor pinecone Community Output processors Community Processor protobuf (Protobuf) Certified Processor pulsar (Pulsar) Community InputOutput pusher Community Output qdrant Community Output rate_limit Certified Processor read_until Community Input redis (Redis) Certified Processor redis_hash Certified Output redis_list Certified InputOutput redis_pubsub Certified InputOutput redis_scan Community Input redis_script Certified Processor redis_streams Certified InputOutput redpanda_data_transform Community Processor reject Community Output reject_errored Community Output resource Community InputOutputProcessor retry Community OutputProcessor schema_registry (Schema Registry) Certified InputOutput schema_registry_decode Certified Processor schema_registry_encode Certified Processor select_parts Certified Processor sentry_capture Community Processor sequence Community Input sftp Certified InputOutput sleep Certified Processor Enterprisesnowflake_put (Snowflake) Certified Output socket (Socket) Certified InputOutput socket_server Certified Input split Community Processor splunk Community Input Enterprisesplunk_hec (Splunk) Certified Output sql_insert MYSQL driver Certified OutputProcessor sql_insert PostgreSQL driver Certified OutputProcessor sql_insert ClickHouse driver Community OutputProcessor sql_insert Microsoft SQL Server driver Community OutputProcessor sql_insert SQLite driver Certified OutputProcessor sql_insert Oracle driver Certified OutputProcessor sql_insert Snowflake driver Community OutputProcessor sql_insert Trino driver Community OutputProcessor sql_insert Azure Cosmos DB driver Community OutputProcessor sql_raw MYSQL driver Certified InputOutputProcessor sql_raw PostgreSQL driver Certified InputOutputProcessor sql_raw ClickHouse driver Community InputOutputProcessor sql_raw Microsoft SQL Server driver Community InputOutputProcessor sql_raw SQLite driver Certified InputOutputProcessor sql_raw Oracle driver Certified InputOutputProcessor sql_raw Snowflake driver Community InputOutputProcessor sql_raw Trino driver Community InputOutputProcessor sql_raw Azure Cosmos DB driver Community InputOutputProcessor sql_select MYSQL driver Certified InputProcessor sql_select PostgreSQL driver Certified InputProcessor sql_select ClickHouse driver Community InputProcessor sql_select Microsoft SQL Server driver Community InputProcessor sql_select SQLite driver Certified InputProcessor sql_select Oracle driver Certified InputProcessor sql_select Snowflake driver Community InputProcessor sql_select Trino driver Community InputProcessor sql_select Azure Cosmos DB driver Community InputProcessor stdin Community Input stdout Community Output subprocess Community InputOutputProcessor switch Community OutputProcessor sync_response Community OutputProcessor try Community Processor unarchive Certified Processor wasm (WebAssembly) Community Processor websocket (WebSocket) Certified InputOutput while Community Processor workflow Certified Processor twitter_search (X/Twitter) Community Input xml (XML) Community Processor zmq4 Community InputOutput Back to top × Simple online edits For simple changes, such as fixing a typo, you can edit the content directly on GitHub. Edit on GitHub Or, open an issue to let us know about something that you want us to change. Open an issue Contribution guide For extensive content updates, or if you prefer to work locally, read our contribution guide . Was this helpful? thumb_up thumb_down group Ask in the community mail Share your feedback group_add Make a contribution Components Support Levels