Hi, I upgraded Flink version from 1.12 to 1.16.1 and the table.connect method is no longer present. I wanted to write Avro records to a Kafka Sink. Can anyone point me to examples that do this in new versions of Flink ?

Have you checked the documentation? If so, what's missing for you?