You are welcome, glad it helped! Best, Alexander Fedulov
On Mon, Jul 18, 2022 at 8:06 PM Salva Alcántara <salcantara...@gmail.com> wrote: > For the record, Alexander Fedulov pointed me to an example within the > kafka connector: > > > https://github.com/apache/flink/blob/025675725336cd572aa2601be525efd4995e5b84/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java#L218 > > Thanks Alexander! >