単一のストームトポロジ内の複数のカフカトピックから正しく読み取る方法

Question

私は、複数のカフカトピックから読み込み、その出力を単一のボルトにストリームする必要があるストームトポロジを持っています。

現在、私はこのコードを使用していますし、それが正常に動作するように表示されます -

final TopologyBuilder topologyBuilder = new TopologyBuilder(); 
topologyBuilder.setSpout(SPOUT_ID_1, new KafkaSpout(kafkaSpoutConfig1), 1); 
topologyBuilder.setSpout(SPOUT_ID_2, new KafkaSpout(kafkaSpoutConfig2), 1); 
topologyBuilder.setBolt(BOLT_ID, new SingleBolt(), 1).shuffleGrouping(SPOUT_ID_1).shuffleGrouping(SPOUT_2); 

が、これは正しいアプローチですか？ shuffleGrouping()を複数回呼び出すのですか？

Answer 1

はい、***Grouping()に複数回電話をかけることができます。