Search code examples
javascalaapache-flinkapache-pulsarpulsar

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?

Solution

  • PulsarSourceBuilder is from Pulsar

    I'd suggest adding this to your pom:

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