找不到Apache flink Kafka连接器

Question

我对flink/Java/Scala相当陌生，所以这可能是一个没有问题的问题，但任何帮助都是值得赞赏的。我还没有找到一个使用Flink 1.13的Flink Kafka连接器的例子(并且为我工作)。

我的项目在这里：https://github.com/sysarcher/flink-scala-tests

我想我不能使用(链接)，我想试一下。

我用的是IntelliJ的想法。项目是从Flink网站教程生成的。

• 第一个问题似乎是提供了如下所建议的范围：https://stackoverflow.com/a/63667067/3760442 .现在，DataStream API (和示例)似乎起作用了。
• 目前的问题是，我无法使用卡夫卡连接器，我想尝试。

下面的链接用于生成项目：https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/try-flink/datastream/#how-to-follow-along

错误遇到

$ mvn clean compile
[INFO] ...
[WARNING] Multiple versions of scala libraries detected
[ERROR] /hide/abs/path/github/flink-stuff/frauddetection/src/main/scala/spendreport/FraudDetectionJob.scala:42: error: not found: type FlinkKafkaConsumer
[ERROR]     val kafkaConsumer = new FlinkKafkaConsumer[String]("car.create", new SimpleStringSchema(), properties)
[ERROR]                             ^
[ERROR] one error found

更新：

一个问题是缺少的import语句：

import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer

我可以使用mvn clean compile构建工件，但是IntelliJ仍然会出现以下错误：

/long/path/flink-stuff/frauddetection/src/main/scala/spendreport/FraudDetectionJob.scala:30:35
object connectors is not a member of package org.apache.flink.streaming
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer

Answer 1

事实证明，问题在于IntelliJ的索引(或者其他什么，我不确定)。我按了CTRL+SHIFT+A，输入了Reload All Maven Projects。此后，建造成功。

这个评论很有帮助：https://lists.apache.org/x/thread.html/rc332d1054886e35af65de4a7c38553e02a2304a2ebdab8197badd94d@%3Cuser.flink.apache.org%3E

似乎有时IntelliJ对索引不起作用，也许您可以从上下文菜单中选择mvn ->重新导入项目，如果它仍然不能工作，也许您可以尝试删除.idea和.iml文件并重新打开该项目。