Storm 控制螺栓发送数据的方式
Storm controlling the way bolts emit data
我有一个小拓扑。它有一个 kafka 喷口，一个从喷口读取的螺栓（螺栓 A）。
螺栓 A 发射到两个螺栓（螺栓 B 和螺栓 C）。我使用了字段分组。
Bolt A 发出两种不同类型的数据。一个用于螺栓 B，另一个用于螺栓 C。
我的问题是，我能否以这样一种方式配置 Storm，即用于 Bolt B 的数据始终转到 Bolt B 的实例并且同样用于 Bolt C？
目前我正在检查螺栓中收到的数据并跳过不需要的数据。
谢谢
使用标准 Storm，最简单的方法是使用 "streams." 您在 declareOutputFields 中使用输出字段声明器上的 declareStream 方法定义一个流，并使用允许您指定流 ID 的 emit 重载版本之一。您还需要使用使螺栓订阅流的 shuffleGrouping 版本。
我有一个小拓扑。它有一个 kafka 喷口，一个从喷口读取的螺栓（螺栓 A）。 螺栓 A 发射到两个螺栓（螺栓 B 和螺栓 C）。我使用了字段分组。 Bolt A 发出两种不同类型的数据。一个用于螺栓 B，另一个用于螺栓 C。
我的问题是，我能否以这样一种方式配置 Storm，即用于 Bolt B 的数据始终转到 Bolt B 的实例并且同样用于 Bolt C？ 目前我正在检查螺栓中收到的数据并跳过不需要的数据。
谢谢
使用标准 Storm，最简单的方法是使用 "streams." 您在 declareOutputFields 中使用输出字段声明器上的 declareStream 方法定义一个流，并使用允许您指定流 ID 的 emit 重载版本之一。您还需要使用使螺栓订阅流的 shuffleGrouping 版本。