Pulsar adaptor for Apache Storm

An application can inject data into a Storm topology via a generic Pulsar spout, as well as consume data from a Storm topology via a generic Pulsar bolt.

The Pulsar Spout allows for the data published on a topic to be consumed by a Storm topology. It emits a Storm tuple based on the message received and the provided by the client.

For a complete example, click here.

A partitioned topic can also be used to publish messages on different topics. In the implementation of the , a “key” will need to be provided in the message which will send the messages with the same key to the same topic. Here’s an example bolt: