You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Vishwas Siravara <vs...@gmail.com> on 2019/09/06 01:47:57 UTC

Flink Kafka Connector

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