Flink Kafka Connector

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view

Flink Kafka Connector

Vishwas Siravara
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 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 : This
creates a big problem, I can connect to the broker but I don't see any messages. 

Why is this ?