Project reactor support

[migroskub]

I’d like to understand whether this project supports and implements the bindings asynchronously with project reactor, or whether it uses synchronous interaction with Pulsar.

[lhotari]

This binder is in early phases and there isn't yet support for Project Reactor.

There's a separate project https://github.com/datastax/reactive-pulsar which contains an Project Reactor / Reactive Streams adapter for the Apache Pulsar Java client. Later on, this could be used to provide reactive support.

Would you like to share your use case for using Project Reactor with this binder? Any specific examples of what type of support you would need for your use case?

[migroskub]

@lhotari I'm using reactive-pulsar already and that's great. The thing is that I'd like to use spring cloud stream but I can't since it doesn't have an available binder for reactive-pulsar yet. A binder for Pulsar is cool and I'd be glad to hear that it exists, but I won't use it since that's not async by nature.

If there'll be a pulsar-spring-cloud-stream-binder-reactive, this will fit my needs and I'll gladly use it.

[lhotari]

Thanks for the feedback @migroskub . I'll take that into consideration.

[dajemet379]

@lhotari I'd also like that. Reactor is more efficient and widely used when it comes to data pipelines