Hi Kadiyala,
I think that there is a typo from your email:
Fink version 1.7.1
May be 1.17.1 ?
About the error, The reason why your code can't run successfully
is: the class
"*org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer" had
been obsolete since Flink 1
Hi,
Please find below the code I have been using to consume a Kafka Stream that is
hosted on confluent. It returns an error regarding the jar files. Please find
the error below the code snippet. Let me know what I am doing wrong. I am
running this on Docker with Flink Version: 1.7.1.
Code:
fr
