风暴从同一个螺栓写入多个 HBase 表？

Question

我有一个风暴拓扑，它从 kafka 主题中读取数据并将其存储到 hbase 表中，我想知道是否有任何方法可以根据 kafka 消息中的数据动态决定将消息写入哪个表?

Answer 1

你使用的是默认的 HBase bolt 吗？

有几种方法可以做到这一点。您可以创建一个实现逻辑的螺栓，并在多个流之一中发出元组，而另一端的 HBase 螺栓订阅正确的流。如果您的逻辑非常复杂，并且执行此操作所需的螺栓数量过多，您总是可以编写一个螺栓来实现您的表选择逻辑和对 HBase 的插入。