Connector Hub
43 sources. 35 sinks. One config grammar.
Every connector shares the same auth, pagination, batching and state model. Each page below shows what the connector guarantees, how mature it is, how to install it and every config field it takes — generated from the engine, so it matches the release you run.
faucet 1.18.2 · crates.io data as of 2026-11-14
Amazon DynamoDB sink Amazon DynamoDB sink; batched writes, upsert/delete by key, conditional writes Amazon DynamoDB source Amazon DynamoDB source; parallel Scan, Query, or Streams CDC with resumable shard bookmarks Amazon Redshift sink Amazon Redshift sink (COPY-from-S3 or multi-row INSERT) Amazon Redshift source Amazon Redshift query source (PostgreSQL wire; streaming rows, incremental replication) Amazon S3 sink AWS S3 object sink Amazon S3 source AWS S3 object source Apache Iceberg sink Apache Iceberg sink (append; REST/Glue/SQL/HMS catalogs) Apache Iceberg source Apache Iceberg source (REST/Glue/SQL/HMS catalogs; projection + filter pushdown, time travel, incremental snapshots) Apache Kafka sink Apache Kafka producer with QueueFull retry and topic routing Apache Kafka source Apache Kafka consumer with idle/max-messages termination Apache Parquet sink Apache Parquet file sink (local path or S3) Apache Parquet source Apache Parquet file source (local, glob, or S3) AWS Kinesis sink AWS Kinesis Data Streams producer with partial-failure retry AWS Kinesis source AWS Kinesis Data Streams consumer with per-shard checkpoints AWS SQS sink AWS SQS sink; batched SendMessageBatch with per-entry retry AWS SQS source AWS SQS source; long-poll ReceiveMessage, delete-after-confirm Azure Blob Storage sink Azure Blob Storage / ADLS Gen2 sink — JSONL files Azure Blob Storage source Azure Blob Storage / ADLS Gen2 source — JSONL, JSON array, or raw text ClickHouse sink ClickHouse sink (HTTP INSERT … FORMAT JSONEachRow; optional async inserts) ClickHouse source ClickHouse query source (HTTP interface, JSONEachRow streaming) Cloud Spanner sink Google Cloud Spanner mutation sink (upsert/delete, exactly-once) Cloud Spanner source Google Cloud Spanner query source (streaming SQL, incremental replication) CSV sink CSV file sink CSV source CSV file source Databricks sink Databricks SQL warehouse sink; append/upsert/delete/overwrite, exactly-once, schema evolution, staged COPY INTO Databricks source Databricks SQL query source (Statement Execution API; typed rows, chunk pagination, incremental) Delta Lake sink Apache Delta Lake sink (append-only; local FS or S3/Azure/GCS) Delta Lake source Apache Delta Lake source (local FS or S3/Azure/GCS; time travel, projection) DuckDB sink DuckDB sink; transaction-wrapped multi-row INSERT (JSON column or auto-mapped) DuckDB source DuckDB query source (file or in-memory), rows streamed as JSON Elasticsearch sink Elasticsearch bulk index sink Elasticsearch source Elasticsearch search / scroll source Google BigQuery sink Google BigQuery streaming-insert sink Google BigQuery source Google BigQuery query source Google Cloud Pub/Sub sink Google Cloud Pub/Sub producer with ordering keys and partial-failure retry Google Cloud Pub/Sub source Google Cloud Pub/Sub consumer with ack at durable page boundaries Google Cloud Storage sink Google Cloud Storage sink — JSONL files Google Cloud Storage source Google Cloud Storage source — JSONL, JSON array, or raw text GraphQL source GraphQL API source with cursor pagination gRPC source gRPC source with dynamic protobuf HTTP sink HTTP POST sink (individual or array batch) JSON Lines sink JSON Lines file sink Local files sink Local file sink; JSONL/JSON/CSV/XML/Excel/Avro/Parquet by extension, rollover, atomic temp+rename, atomic overwrite Local files source Local file source; path/dir/glob/URL, every file format incl. Avro/ORC/Parquet, incremental by mtime or name Microsoft SQL Server sink Microsoft SQL Server sink Microsoft SQL Server source Microsoft SQL Server query source MongoDB sink MongoDB insert sink MongoDB source MongoDB query source MongoDB CDC source MongoDB CDC source (Change Streams) MySQL sink MySQL sink MySQL source MySQL query source MySQL CDC source MySQL CDC source (binlog replication) NATS sink NATS sink; publish records to a subject, flush per batch NATS source NATS source; subject/JetStream drain with idle/max termination Oracle CDC source Oracle CDC via LogMiner; committed-transaction change events, SCN bookmarks, exactly-once; needs Oracle Instant Client Oracle Database sink Oracle Database sink; array DML, MERGE upsert/delete, overwrite, exactly-once, schema evolution; needs Oracle Instant Client Oracle Database source Oracle Database query source (ODPI-C); incremental replication, PK-range sharding, discovery; needs Oracle Instant Client PostgreSQL sink PostgreSQL sink (JSONB or auto-mapped columns) PostgreSQL source PostgreSQL query source PostgreSQL CDC source PostgreSQL CDC source (logical replication) RabbitMQ sink RabbitMQ (AMQP 0.9.1) sink; exchange publish, per-record routing key, publisher confirms RabbitMQ source RabbitMQ (AMQP 0.9.1) source; queue consume, ack after sink confirm, idle/max termination Redis sink Redis (streams, lists, key-value) sink Redis source Redis (streams, lists, keys) source REST source REST API source with pagination, auth, transforms SFTP sink SFTP sink; JSONL objects, atomic temp+rename upload SFTP source SFTP source; list/glob a remote dir, stream JSONL/JSON-array/raw-text Singer bridge sink Singer target bridge (runs an external Singer target; bookmarks advance after the target confirms) Singer bridge source Singer tap bridge (runs an external Singer tap) Snowflake sink Snowflake SQL REST API sink Snowflake source Snowflake query source (SQL REST API) SQL Server CDC source Microsoft SQL Server CDC source (change data capture, exactly-once capable) SQLite sink SQLite sink SQLite source SQLite query source Stdout sink Stdout / stderr sink (JSON Lines, pretty, TSV) Webhook source Webhook HTTP receiver source WebSocket source WebSocket streaming source XML / SOAP source XML / SOAP API source with XML→JSON conversion
No connector matches. Clear a filter, or search for the system’s name.
File formats: the local-file and object-store connectors read and write JSONL, JSON, CSV, Excel, XML, Parquet and Avro, and read ORC, picked per file by extension or set explicitly (file formats). The Singer bridges run any existing tap as a source and any Singer target as a sink.
The same capabilities side by side, for every connector at once, are in the capability matrix.
Community connectors
Any crate published to crates.io as faucet-source-<name> or
faucet-sink-<name> is listed here automatically. They are not
conformance-scored, since the hub only reads their crates.io metadata.
No community connectors on crates.io yet. Build one with
the connector guide and publish it as
faucet-source-<name> or faucet-sink-<name> — it shows up here on the next site build.
Get started
Your first pipeline runs in five minutes.
Install the CLI, scaffold a config, and move real data — nothing external to stand up.
curl -LsSf https://github.com/faucet-hq/faucet-stream/releases/latest/download/faucet-cli-installer.sh | sh brew install faucet-hq/faucet-stream/faucet-cli