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

Question

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

Answer 1

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

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