Re: Apache Flink Kafka Connector not found Error

2021-07-19 Thread Taimoor Bhatti
afkaConsumer "mvn clean compile" works however... (Thanks...) Do you know why IntelliJ doesn't see the import?? Best, Taimoor From: Yun Gao Sent: Monday, July 19, 2021 3:25 PM To: Taimoor Bhatti ; user@flink.apache.org Subject: Re: Apache Flink

Re: Apache Flink Kafka Connector not found Error

2021-07-19 Thread Taimoor Bhatti
mport org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer "mvn clean compile" works however... (Thanks...) Do you know why IntelliJ doesn't see the import?? Best, Taimoor From: Yun Gao Sent: Monday, July 19, 2021 3:25 PM To: Taimoor Bhatti ; user@flink.apache.org Subject: Re: Apache F

Apache Flink Kafka Connector not found Error

2021-07-19 Thread Taimoor Bhatti
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