A Server-Sent-Event implementation based on the SseEmitter from Spring. The server provides a rest api to create a new event stream and subscribe to the event data. from the project root. This will ...

Simple steps to start using the library. Annotate your service method with @PulsarConsumer annotation and set batch attribute to true. Return a list from your consumer method, which contains MessageId ...