我有一个风暴拓扑,必须阅读多个Kafka主题和流式输出到一个螺栓。
目前我正在使用这个代码,它似乎是工作fine:-
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()
多次?
1条答案
按热度按时间5lhxktic1#
是的,你可以打电话
***Grouping()
多次。