未找到 Apache flink Kafka 连接器答案

【问题标题】：Apache flink Kafka Connector not found未找到 Apache flink Kafka 连接器
【发布时间】：2023-03-07 09:15:01
【问题描述】：

我对 flink/Java/Scala 还很陌生，所以这可能不是问题，但感谢您的帮助。我无法找到将 Flink Kafka 连接器与 Flink 1.13 结合使用的示例（并且适用于我）。

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

我想我无法使用我想尝试的FlinkKafkaConsumer (link)。

我正在使用 IntelliJ Idea。该项目是从tutorial on Flink's website生成的

第一个问题似乎是此处建议的提供范围：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-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

【问题讨论】：

标签： apache-flink flink-streaming

【解决方案1】：

原来问题出在 IntelliJ 的索引上（或者其他什么，我不确定）。我按下CTRL+SHIFT+A 并输入Reload All Maven Projects。此后，构建成功。

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

IntelliJ 似乎有时不能很好地用于索引，也许你可以从上下文菜单中选择 mvn -> reimport project，如果它仍然不起作用，也许你可以尝试删除 .idea 和 .iml 文件并重新打开再次项目。

【讨论】：