Hi all, We're looking to migrating from FlinkKafkaProducer to the new KafkaSink for the new unified Sink API.
Is the state compatible across the two Kafka sink APIs? If not, what's the best way to migrate from one to the other? Thanks in advance, Kevin
