Hi Taimoor, I think it is right regarding the provided dependency and we need to use manually included them in the classpath via the IDEA options.
And regarding the FlinkKafkaConsumer issue, I tried locally and it seems it could work after adding the import ? Namely import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer Best, Yun ------------------------------------------------------------------ From:Taimoor Bhatti <taimoorbha...@outlook.com> Send Time:2021 Jul. 19 (Mon.) 18:43 To:user@flink.apache.org <user@flink.apache.org> Subject:Apache Flink Kafka Connector not found Error I'm having some trouble with using the Flink DataStream API with the Kafka Connector. There don't seem to be great resources on the internet which can explain the issue I'm having. My project is here: https://github.com/sysarcher/flink-scala-tests I want to I'm unable to use FlinkKafkaConsumer (link) which I want to try out. I'm using IntelliJ Idea. The project was generated from the tutorial on Flink's website The First problem seemed to be the provided scope as suggested here: https://stackoverflow.com/a/63667067/3760442 ... Now, DataStream API (and the example) seem to work. The current problem is that I'm not able to use the Kafka connector which I'm looking to try out. The following link was used to generate the project: https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/try-flink/datastream/#how-to-follow-along This same question was originally posted here: https://stackoverflow.com/q/68437215/3760442 Thanks in advance
