flink

Flink SQL: Could not execute SQL statement. Reason: java.io.IOException: Corrupt Debezium JSON message · · flink kafka

Flink SQL: Exporting nested JSON to a Kafka topic · · flink kafka