Storm 控制螺栓发出数据的方式答案

【问题标题】：Storm controlling the way bolts emit dataStorm 控制螺栓发出数据的方式
【发布时间】：2015-03-16 09:05:18
【问题描述】：

我有一个小型拓扑。它有一个卡夫卡喷口，一个从喷口读取的螺栓（螺栓 A）。螺栓 A 发射到两个螺栓（螺栓 B 和螺栓 C）。我使用了字段分组。 Bolt A 发出两种不同类型的数据。一个用于螺栓 B，另一个用于螺栓 C。

我的问题是，我能否以这样的方式配置 Storm，即用于 Bolt B 的数据总是用于 Bolt B 的实例，而用于 Bolt c 的数据也是如此？目前我正在检查螺栓中收到的数据并跳过不需要的数据。

谢谢

【问题讨论】：

【解决方案1】：

对于标准 Storm，最简单的方法是使用“流”。您使用输出字段声明器上的declareStream 方法在declareOutputFields 中定义一个流，并使用允许您指定流ID 的emit 的重载版本之一进行发射。您还需要使用使螺栓订阅流的shuffleGrouping 版本。

【讨论】：