I’m consuming a Kafka topic with Flink using the Table API, pretty much like this:

I’m consuming a Kafka topic with Flink using the Table API, pretty much like this:

I’m consuming a Kafka topic with Flink using the Table API, pretty much like this:

I need to write a flink udf that can return Map<String, Object>, how do I achieve this.

Flink version : 1.19.0

Flink version : 1.19.0

I am trying to read data from an event outbox table and then have two sinks , one to push the event to a Kafka topic and other to update the table in same database using Flink. Since I want these two sinks to have exactly once delivery semantics , I am using JDBC Sink for that. Below is code for this.

I am trying to run a flink job locally reading from a local iceberg table