如何正确阅读多个Kafka主题在一个单一的风暴拓扑

klsxnrf1  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(353)

我有一个风暴拓扑,必须阅读多个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() 多次?

5lhxktic

5lhxktic1#

是的,你可以打电话 ***Grouping() 多次。

相关问题