我想让 Flink 从 Pulsar 读取
I would like to enable Flink to read from Pulsar
我是 Pulsar 新手！
现在，我正尝试在 Scala 中实现这些代码（https://flink.apache.org/2019/05/03/pulsar-flink.html）。但是，我找不到一些 类（例如 PulsarSourceBuild）。
我怎样才能在 Scala 中完成它们？我应该在哪里检查？
PulsarSourceBuilder 来自 Pulsar
我建议将此添加到您的 pom：
<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-flink</artifactId>
<version>2.6.0</version>
</dependency>
我是 Pulsar 新手！
现在，我正尝试在 Scala 中实现这些代码（https://flink.apache.org/2019/05/03/pulsar-flink.html）。但是，我找不到一些 类（例如 PulsarSourceBuild）。
我怎样才能在 Scala 中完成它们？我应该在哪里检查？
PulsarSourceBuilder 来自 Pulsar
我建议将此添加到您的 pom：
<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-flink</artifactId>
<version>2.6.0</version>
</dependency>