Hi All,

We have a usecase for pulsar with spark streaming and for the same I was
looking at the pulsar-spark receiver (SparkStreamingPulsarReceiver.java).

This does not provide features like reliability, ratelimit, backpressure
considerations, pulsar message metadata, etc. Hence I ended up writing my
own receiver with all these features but the same core logic of
`SparkStreamingPulsarReceiver.java`.

I was wondering if we could add this receiver too in the repo and hence
raise a PR for the same.
https://github.com/apache/pulsar-adapters/pull/31

Let me know what you guys think.

Thanks and Regards
Aditya Tiwari

Reply via email to