GitHub user svenhornberg created a discussion: Apache Beam support for Pulsar
I would like to use Apache Beam and Pulsar as my source, for writing my batch or streaming jobs. Please consider adding a PulsarIO class to the sdk like Kafka (https://beam.apache.org/releases/javadoc/2.4.0/org/apache/beam/sdk/io/kafka/KafkaIO.html) I found the pulsar-flink and pulsar-spark folders, but i really like the Apache Beam API. Maybe you could add a pulsar-beam example or subfolder GitHub link: https://github.com/apache/pulsar/discussions/18453 ---- This is an automatically sent email for dev@pulsar.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@pulsar.apache.org
