Pulsar adaptor for Apache Storm

应用程序可以通过通用的 Pulsar spout 将数据写入到 Storm 拓扑中，也可以利用通用的 Pulsar bolt 来使用来自 Storm 拓扑的数据。

Pulsar Spout 允许 Storm topology 消费发布到 topic 的数据。 它根据收到的消息和客户端提供的 发出 Storm tuple。

点击这里查看完整示例.

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: