alexec opened a new issue #12428: URL: https://github.com/apache/pulsar/issues/12428
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](https://github.com/argoproj-labs/argo-dataflow/commit/11251f5806ed8bfbd9e6b5017259c19b006118ca), breaking it down: 1. Add manifests to install a dev Pulsar into Kubernetes cluster. 2. Add APIs to specify a Pulsar source and sink (e.g. the URL, authentication). 3. Implement the source and sink. 4. Write test infrastructure (e.g. check the right number of messages get written to a sink). 5. Write tests (e.g. does the right number of message get written, even if the pod is deleted). 6. Write examples. 7. Write docs. I'll raise a ticket against the main repo, and the Go client repo (there might be engineers there with the exact skills needed). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
