A [single|uber|fat] jar standalone Apache Flink connected to PostgreSQL via Ververica CDC connector. Usage Flink SQL to replicate data from PostgreSQL to Elasticsearch/something else.
elasticsearch postgres replication postgresql elastic flink cdc debezium flink-stream-processing flink-streaming flink-sql debezium-connector flink-cdc debezium-embedded ververica-connector
-
Updated
May 26, 2024 - Kotlin