Hi, We are currently running Flink 1.11 and I am exploring the option of using the universal Kafka connector with our Kafka cluster running on Kafka version 1.1.1 but log message format version 0.10.2.0.
On the wiki page of the connector ( https://nightlies.apache.org/flink/flink-docs-release-1.11/dev/connectors/kafka.html#dependency), it is mentioned that "Modern Kafka clients are backwards compatible with broker versions 0.10.0 or later. For most users the universal Kafka connector is the most appropriate. However, for Kafka versions 0.11.x and 0.10.x, we recommend using the dedicated 0.11 and 0.10 connectors, respectively." I wanted to ask if anyone has run their Flink 1.11 applications with the universal Kafka connector producing and consuming from a Kafka cluster on log message format version 0.10.2.0. Looking forward to hearing from you, thank you.
