LZ4 compression for Java, based on Yann Collet's work available at http://code.google.com/p/lz4/. This library provides access to two compression methods that both ...

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 ...