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
Locked
