Hi guys, I am using flink connector for kakfa from 1.9.0 Her is my sbt dependency :
"org.apache.flink" %% "flink-connector-kafka" % "1.9.0", When I check the log file I see that the kafka version is 0.10.2.0. According to the docs it says that 1.9.0 onwards the version should be 2.2.0. Why do I see this 2019-09-06 01:41:43,534 INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.2.0. This creates a big problem, I can connect to the broker but I don't see any messages. Why is this ? Thanks, Vishwas
