In Dataflow, we currently have support for Kafka, Jetstream, NATS Streaming and other sources and sinks. It would be amazing to add support for Pulsar too. We know that we plenty of use cases in the OSS community and this would get a lot of love.
The Dataflow team are not Pulsar experts. My ask is - would anyone be interested in implementing the changes needed?
Original Issue: apache/pulsar-client-go#643
In Dataflow, we currently have support for Kafka, Jetstream, NATS Streaming and other sources and sinks. It would be amazing to add support for Pulsar too. We know that we plenty of use cases in the OSS community and this would get a lot of love.
The Dataflow team are not Pulsar experts. My ask is - would anyone be interested in implementing the changes needed?
Here is a pull request for Jetstream, breaking it down:
I'll raise a ticket against the main repo, and the Go client repo (there might be engineers there with the exact skills needed).