导入KafkaSource在中不起作用

Question

我尝试在Google上Shell中的ssh控制台中导入这个库：

import org.apache.flink.connector.kafka.source.KafkaSource

我以前安装过flink：

wget https://dlcdn.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz
tar -xzf flink-1.14.4-bin-scala_2.11.tgz

但是，当我运行导入行时，我会得到以下错误：

<console>:81: error: object kafka is not a member of package org.apache.flink.connector
       import org.apache.flink.connector.kafka.source.KafkaSource

有什么问题吗？我有一个正确的flink和scala版本。我需要这个从flink内部得到卡夫卡的数据。

(但在Intellij的导入工作很棒.)

Answer 1

Flink不随卡夫卡连接器而来。您需要手动将其添加到类路径中。

https://mvnrepository.com/artifact/org.apache.flink/flink-connector-kafka

Intellij导入中的

工作得很好

你在用Maven/SBT/Gradle吗？然后，听起来您已经将上面的包作为一个项目依赖项包含了，您应该将代码打包成一个uber JAR，并将其上传到GCP，而不是简单地使用Scala