Re: Apache Flink Kafka Connector not found Error

2021-07-19 Thread Taimoor Bhatti 
THANKSS...

This was it!! I did:-

CTRL+SHIFT+A and typed "Reload All Maven Projects"

Building the project didn't result in errors. I don't think I could've resolved 
this...

Thanks again Yun!!!

From: Yun Gao 
Sent: Monday, July 19, 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 might try remove the .idea and .iml
file and re-open the project again.

Best,
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 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 
Sent: Monday, July 19, 2021 3:25 PM
To: Taimoor Bhatti ; 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 
Send Time:2021 Jul. 19 (Mon.) 18:43
To: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=04%7C01%7C%7C438129e5dd6c43e4f59308d94ac92007%7C84df9e7fe9f640afb435%7C1%7C0%7C637623049949903439%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000=rlvS8vJQkgqV55%2FPReEEPZENnqh%2B6JeJ7jDgq%2FyFpDg%3D=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=04%7C01%7C%7C438129e5dd6c43e4f59308d94ac92007%7C84df9e7fe9f640afb435%7C1%7C0%7C637623049949903439%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000=yYdca%2FPa0fV7YwcmJZFJiLUW5motdY2JAYn20XaDpLs%3D=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=04%7C01%7C%7C438129e5dd6c43e4f59308d94ac92007%7C84df9e7fe9f640afb435%7C1%7C0%7C637623049949913395%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000=q0aWqThkCCHRX3RLlqbviKcmdSelV3gZLqvp32JK%2BkY%3D=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=04%7C01%7C%7C438129e5dd6c43e4f59308d94ac92007%7C84df9e7fe9f640afb435%7C1%7C0%7C637623049949913395%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000=Jbs40RESUJvuJDmbGZ6mhIZF7ZTPwoU7S3I9IpMQLuQ%3D=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=04%7C01%7C%7C438129e5dd6c43e4f59308d94ac92007%7C84df9e7fe9f640afb435%7C1%7C0%7C637623049949923341%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000=w7Zkp315lty0C

Re: Apache Flink Kafka Connector not found Error

2021-07-19 Thread Yun Gao 
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 might try remove the .idea and .iml
file and re-open the project again.

Best,
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 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 
Sent: Monday, July 19, 2021 3:25 PM
To: Taimoor Bhatti ; 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 
Send Time:2021 Jul. 19 (Mon.) 18:43
To: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

Re: Apache Flink Kafka Connector not found Error

2021-07-19 Thread Taimoor Bhatti 
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 
Sent: Monday, July 19, 2021 3:25 PM
To: Taimoor Bhatti ; 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 
Send Time:2021 Jul. 19 (Mon.) 18:43
To: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=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435%7C1%7C0%7C637622979351659599%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000=vRK2%2FRqQqGKU39oqAABpFQ8%2BNS5pgaZ2iehWrVFW2QE%3D=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=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435%7C1%7C0%7C637622979351659599%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000=kiwVPBqcmxvqy9NsK%2F3PNkotaFP1pKn2QUWxn%2BVHb38%3D=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=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435%7C1%7C0%7C637622979351669554%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000=NrnA65zYyW87G2tNrXAHl0%2F28j%2FMlkB05PKYWB29kY8%3D=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=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435%7C1%7C0%7C637622979351669554%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000=R7NUhLiSAMn2gUUqTewKKFxoukIfvSAhCAwtEaCEJj0%3D=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=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435%7C1%7C0%7C637622979351679514%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000=stA63tMKQDzJEy5oS6BUpaQwLu%2Fvr78yK0y8TwYR5gY%3D=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=04%7C01%7C%7C0d8f727f0c8e42a94f0008d94ab8b04e%7C84df9e7fe9f640afb435%7C1%7C0%7C637622979351679514%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000=k4mrQ5NCv1%2BCOs7xycqtaBOH%2Ff57vSB39%2BeGibzT3nQ%3D=0>

Thanks in advance

Re: Apache Flink Kafka Connector not found Error

2021-07-19 Thread Yun Gao 
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 
Send Time:2021 Jul. 19 (Mon.) 18:43
To: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

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 
(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