Sources
GlassFlow connects to a growing list of data sources and streams them into ClickHouse with deduplication, joins, filtering, and stateless transformations.
Sources marked ‘Enterprise’ are delivered as part of GlassFlow’s Enterprise Edition. To get access to our managed connectors or request a new connector, get in touch with our team here
| Source | Category | Version |
|---|---|---|
| Apache Kafka® | Streaming | Open Source |
| AWS CloudWatch | Telemetry | Open Source |
| AWS MSK | Streaming (Kafka-compatible) | Open Source |
| Confluent Cloud | Streaming (Kafka-compatible) | Open Source |
| Fluent Bit | Telemetry collector | Open Source |
| Fluentd | Telemetry collector | Open Source |
| Grafana Alloy | Telemetry collector | Open Source |
| Logstash | Telemetry collector | Open Source |
| OpenTelemetry (OTLP) | Telemetry | Open Source |
| Redpanda | Streaming (Kafka-compatible) | Open Source |
| WarpStream | Streaming (Kafka-compatible) | Open Source |
| Airbyte | Data integration | Enterprise |
| Amazon S3 | Object storage | Enterprise |
| Apache Cassandra® | Database | Enterprise |
| Apache Iceberg® | Table format | Enterprise |
| AWS Kinesis | Streaming | Enterprise |
| Azure Event Hubs | Streaming | Enterprise |
| Delta Lake | Table format | Enterprise |
| DynamoDB | Database | Enterprise |
| Google Cloud Storage | Object storage | Enterprise |
| Google Pub/Sub | Streaming | Enterprise |
| Kinesis Firehose | Streaming | Enterprise |
| MariaDB | Database | Enterprise |
| MongoDB | Database | Enterprise |
| MySQL | Database | Enterprise |
| Neon | Database | Enterprise |
| PostgreSQL | Database | Enterprise |
| PostHog | Product analytics | Enterprise |
| Segment | Customer data platform | Enterprise |
| Supabase | Database | Enterprise |
| Webhook (HTTP) | HTTP | Enterprise |
Missing an integration? Let us know which source you need and we’ll deliver it within a few weeks. Contact us with your use case, expected volumes, and timeline—or join our GlassFlow Slack community to chat with us directly!
How sources work
All source types feed into the same pipeline runtime. Once data is ingested, every source supports:
- Deduplication — drop duplicate records based on a key and time window
- Filtering — keep only records matching an expression
- Stateless transformations — map fields, derive values, reshape records
- Joins — combine related streams (Kafka sources only)
Output is always written to ClickHouse via the same sink configuration.
Last updated on