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

huangapple go评论42阅读模式
英文:

I would like to enable Flink to read from Pulsar

问题

I’m new to Pulsar!

Now, I am trying to implement these codes( https://flink.apache.org/2019/05/03/pulsar-flink.html ) in Scala. However, I can’t find some classes(e.g. PulsarSourceBuild).
How can I do them in Scala? Where should I check?

英文:

I’m new to Pulsar!

Now, I am trying to implement these codes( https://flink.apache.org/2019/05/03/pulsar-flink.html ) in Scala. However, I can’t find some classes(e.g. PulsarSourceBuild).
How can I do them in Scala? Where should I check?

答案1

得分: 0

PulsarSourceBuilder来自Pulsar

我建议将此添加到您的pom文件中:

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

PulsarSourceBuilder is from Pulsar

I'd suggest adding this to your pom:

&lt;dependency&gt;
    &lt;groupId&gt;org.apache.pulsar&lt;/groupId&gt;
    &lt;artifactId&gt;pulsar-flink&lt;/artifactId&gt;
    &lt;version&gt;2.6.0&lt;/version&gt;
&lt;/dependency&gt;

huangapple
  • 本文由 发表于 2020年7月28日 14:15:21
  • 转载请务必保留本文链接:https://go.coder-hub.com/63128086.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定