Guest
This talk introduces a new open source library that adapts the Apache Pulsar Java Client to Reactive Streams. This allows building non-blocking, reactive applications with Apache Pulsar and Spring Boot that can leverage the full extent of Spring Reactive and its built-in resilience features, such as reactive non-blocking backpressure, timeout handling, retries with backoffs/jitter, and rate-limiting. The talk will focus on explaining why a reactive programming model is useful for working with Apache Pulsar and how the new open source library adapts the Apache Pulsar Java Client’s asynchronous API to Reactive Streams with Project Reactor. This talk also demonstrates how non-blocking asynchronous backpressure handling, failure tolerance, and resilience can be achieved in processing Pulsar messages using the adapter library and Spring Reactive in a Spring Boot application.
