2021 5:23 PM
To: Taimoor Bhatti ; user@flink.apache.org
Subject: Re: Apache Flink Kafka Connector not found Error
Hi Taimoor,
It seems sometime IntelliJ does not works well for index, perhaps
you could choose mvn -> reimport project from the context menu,
if it still not work, perhaps you mi
Yun
--
From:Taimoor Bhatti
Send Time:2021 Jul. 19 (Mon.) 23:03
To:user@flink.apache.org ; Yun Gao
Subject:Re: Apache Flink Kafka Connector not found Error
Hello Yun,
Many thanks for the reply...
For some reason I'm not able t
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
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.stre
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
