找不到Apache flink Kafka连接器

Question

我对flink/Java/Scala还比较陌生，所以这可能不是问题，但非常感谢您的帮助。我还没有找到一个将Flink Kafka连接器与Flink 1.13结合使用的示例（对我适用）。

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

我想我无法使用我想试用的FlinkKafkaConsumer（链接）。

我正在使用IntelliJ Idea。该项目是从Flink网站上的教程生成的

• 第一个问题似乎是此处建议的提供范围：https://stackoverflow.com/a/63667067/3760442。。。现在，DataStream API（和示例）似乎可以工作了
• 目前的问题是，我无法使用我正在尝试的Kafka连接器

以下链接用于生成项目：https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/try-flink/datastream/#how-跟随

遇到错误

$ 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键，然后键入“重新加载所有Maven项目”。此后，构建成功。

此评论有助于：https://lists.apache.org/x/thread.html/rc332d1054886e35af65de4a7c38553e02a2304a2ebdab8197badd94d@<用户。Flink。阿帕奇。组织>

有时IntelliJ似乎不能很好地用于索引，也许您可以选择mvn-