我尝试在Google Cloud上的Scala 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版本。我需要这个从kafka内部flink获取数据。
(但在Intellij导入工作很好…)
Flink不是Kafka连接器自带的。您需要手动将其添加到您的类路径
https://mvnrepository.com/artifact/org.apache.flink/flink-connector-kafka
Intellij import works great
你使用Maven/SBT/Gradle吗?那么听起来你已经把上面的包作为一个项目依赖，你应该把你的代码捆绑成一个uber JAR并上传到GCP，而不是简单地使用Scala REPL