Streaming CDC → Kafka → Flink → ClickHouse
Sources
Postgres DB1
Postgres DB2
Postgres DB3
Kafka Connect • Debezium CDC
CDC Task 1
CDC Task 2
CDC Task 3
Kafka Broker (Topics)
Resource 1
Resource 2
Resource 3
Resource 4
Resource 5
Apache Flink SQL
Job 1
Job 2
Job 3
Job 4
Report Topics
Report 1
Report 2
Report 3
Report 4
Kafka Sink
Kafka Connector Sink
ClickHouse (Data Warehouse)
ClickHouse