Connectors
SQL Stream Builder (SSB) supports different connector types and data formats for Flink SQL tables to ease development and access to all kinds of data sources.
The following table summarizes the supported connectors and how they can be used in SSB:
| Connector | Type | Description |
|---|---|---|
| Kafka | source/sink | Supported as exactly-once-sink |
| Hive | source/sink | Can be used as catalog |
| Kudu | source/sink | Can be used as catalog |
| Schema Registry | source/sink | Can be used as catalog |
| Iceberg | source/sink | Can be used with Flink SQL. Hive and HDFS catalog is supported. |
| JDBC | source/sink | Can be used with Flink SQL. PostgreSQL, MySQL and Hive are supported. |
| Filesystems | source/sink | Filesystems such as HDFS, S3 and so on. Can be used with Flink SQL |
| Debezium CDC | source | Can be used with Flink SQL. PostgreSQL, MySQL, Oracle DB, Db2 and SQL Server are supported. |
| Webhook | sink | Can be used as HTTP POST/PUT with templates and headers |
| PostgreSQL | sink | Materialized View connection for reading views. Can be used with anything that reads PostgreSQL wire protocol |
| REST | sink | Materialized View connection for reading views. Can be used with anything that reads REST (such as notebooks, applications, and so on) |
| BlackHole | sink | Can be used with Flink SQL. |
