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.

Pulsar Spout允许通过 Storm topology 发布数据到一个topic用以消费. It emits a Storm tuple based on the message received and the provided by the client.

The Pulsar bolt allows data in a Storm topology to be published on a topic. It publishes messages based on the Storm tuple received and the provided by the client.

You can find a complete example .