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