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?
Copyright © 2021 Jogjafile Inc.
PulsarSourceBuilder is from Pulsar
I'd suggest adding this to your pom: