java风暴控制螺栓发出数据的方式
我有一个小拓扑。它有一个卡夫卡喷口，一个从喷口读取的螺栓（螺栓a）。 螺栓A发射到两个螺栓（螺栓B和螺栓C）。我使用了字段分组。 螺栓A发出两种不同类型的数据。一个用于螺栓B，另一个用于螺栓C
我的问题是，我能否以这样的方式配置storm，即螺栓B的数据总是转到螺栓B的实例，螺栓c的数据总是转到螺栓B的实例？ 目前，我正在检查螺栓中收到的数据，并跳过不需要的数据
谢谢
你可以在下面搜索框中键入要查询的问题!
我有一个小拓扑。它有一个卡夫卡喷口，一个从喷口读取的螺栓（螺栓a）。 螺栓A发射到两个螺栓（螺栓B和螺栓C）。我使用了字段分组。 螺栓A发出两种不同类型的数据。一个用于螺栓B，另一个用于螺栓C
我的问题是，我能否以这样的方式配置storm，即螺栓B的数据总是转到螺栓B的实例，螺栓c的数据总是转到螺栓B的实例？ 目前，我正在检查螺栓中收到的数据，并跳过不需要的数据
谢谢
# 1 楼答案
对于标准Storm，最简单的方法是使用“streams”您可以使用输出字段declarer上的
declareStream方法在declareOutputFields中定义一个流，并使用其中一个重载版本的emit来指定流ID。您还需要使用使bolt订阅流的shuffleGrouping版本