Hello Yun, Many thanks for the reply... For some reason I'm not able to import org.apache.flink.streaming.connectors within the IDE...
I get the following errors: object connectors is not a member of package org.apache.flink.streaming import 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 <yungao...@aliyun.com> Sent: Monday, July 19, 2021 3:25 PM To: Taimoor Bhatti <taimoorbha...@outlook.com>; user@flink.apache.org <user@flink.apache.org> Subject: Re: Apache Flink Kafka Connector not found Error 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<https://emea01.safelinks.protection.outlook.com/?url=https%3A%2F%2Fgithub.com%2Fsysarcher%2Fflink-scala-tests&data=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435aaaaaaaaaaaa%7C1%7C0%7C637622979351659599%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000&sdata=vRK2%2FRqQqGKU39oqAABpFQ8%2BNS5pgaZ2iehWrVFW2QE%3D&reserved=0> I want to I'm unable to use FlinkKafkaConsumer (link)<https://emea01.safelinks.protection.outlook.com/?url=https%3A%2F%2Fgithub.com%2Fsysarcher%2Fflink-scala-tests%2Fblob%2Fmain%2Fsrc%2Fmain%2Fscala%2Fspendreport%2FFraudDetectionJob.scala%23L42&data=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435aaaaaaaaaaaa%7C1%7C0%7C637622979351659599%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000&sdata=kiwVPBqcmxvqy9NsK%2F3PNkotaFP1pKn2QUWxn%2BVHb38%3D&reserved=0> which I want to try out. I'm using IntelliJ Idea. The project was generated from the tutorial on Flink's website<https://emea01.safelinks.protection.outlook.com/?url=https%3A%2F%2Fci.apache.org%2Fprojects%2Fflink%2Fflink-docs-release-1.13%2Fdocs%2Ftry-flink%2Fdatastream%2F%23how-to-follow-along&data=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435aaaaaaaaaaaa%7C1%7C0%7C637622979351669554%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000&sdata=NrnA65zYyW87G2tNrXAHl0%2F28j%2FMlkB05PKYWB29kY8%3D&reserved=0> * The First problem seemed to be the provided scope as suggested here: https://stackoverflow.com/a/63667067/3760442<https://emea01.safelinks.protection.outlook.com/?url=https%3A%2F%2Fstackoverflow.com%2Fa%2F63667067%2F3760442&data=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435aaaaaaaaaaaa%7C1%7C0%7C637622979351669554%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000&sdata=R7NUhLiSAMn2gUUqTewKKFxoukIfvSAhCAwtEaCEJj0%3D&reserved=0> ... 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<https://emea01.safelinks.protection.outlook.com/?url=https%3A%2F%2Fci.apache.org%2Fprojects%2Fflink%2Fflink-docs-release-1.13%2Fdocs%2Ftry-flink%2Fdatastream%2F%23how-to-follow-along&data=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435aaaaaaaaaaaa%7C1%7C0%7C637622979351679514%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000&sdata=stA63tMKQDzJEy5oS6BUpaQwLu%2Fvr78yK0y8TwYR5gY%3D&reserved=0> This same question was originally posted here: https://stackoverflow.com/q/68437215/3760442<https://emea01.safelinks.protection.outlook.com/?url=https%3A%2F%2Fstackoverflow.com%2Fq%2F68437215%2F3760442&data=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435aaaaaaaaaaaa%7C1%7C0%7C637622979351679514%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000&sdata=k4mrQ5NCv1%2BCOs7xycqtaBOH%2Ff57vSB39%2BeGibzT3nQ%3D&reserved=0> Thanks in advance
