java - 我想让 Flink 能够从 Pulsar 读取数据

Question

我是脉冲星的新手！

现在，我正在尝试在 Scala中实现这些代码（ https://flink.apache.org/2019/05/03/pulsar-flink.html ）。但是，我找不到一些课程（例如PulsarSourceBuild）。我怎样才能在 Scala 中完成它们？我应该在哪里检查？

Answer 1

PulsarSourceBuilder 来自Pulsar

我建议将此添加到您的 pom 中：

<dependency>
    <groupId>org.apache.pulsar</groupId>
    <artifactId>pulsar-flink</artifactId>
    <version>2.6.0</version>
</dependency>