pulsar-client-reactive

Pulsar Client

Provides a reactive client for interacting with Apache Pulsar message broker using Project Reactor

Reactive client for Apache Pulsar

GitHub

60 stars
33 watching
18 forks
Language: Java
last commit: 7 days ago
apache-pulsarbackpressureproject-reactorpulsarreactive-streams

Related projects:

Repository Description Stars
apache/pulsar-client-cpp A C++ client library for interacting with the Apache Pulsar messaging system 54
apache/pulsar-client-node A Node.js client library for interacting with Pulsar, a pub/sub messaging system. 148
apache/pulsar-client-ruby A Ruby client for interacting with Apache Pulsar's messaging system 8
apache/pulsar-dotpulsar A .NET client library for Apache Pulsar message broker 234
apache/pulsar-client-python A Python client library for connecting to and interacting with a distributed message broker 53
apache/pulsar-client-go A Go client library for Apache Pulsar messaging service 659
apache/pulsar A distributed messaging platform providing scalable pub-sub capabilities with strong ordering and consistency guarantees. 14,252
apache/pulsar-adapters This repository provides adapters for integrating various messaging and streaming technologies with Apache Pulsar 24
apache/pulsar-site The Apache Pulsar site repository hosts the website and documentation for an open-source distributed messaging platform 38
clevercloud/pulsar4s A Scala client for Apache Pulsar that provides a reactive, type-safe interface to produce and consume messages in a distributed messaging system. 227
jetty-project/jetty-reactive-httpclient A ReactiveStreams wrapper around Jetty's HttpClient 72
apache/pulsar-test-infra Custom GitHub Actions and workflows for automating testing and validation of Apache Pulsar projects. 18
apache/pulsar-manager A web-based GUI management tool for Pulsar clusters 520
vietj/reactive-pg-client A high-performance client for interacting with PostgreSQL databases using reactive and non-blocking connections. 74
reactivecouchbase/reactivecouchbase-rs-core Provides a reactive programming model for interacting with NoSQL databases 26