如何在单个 Storm 拓扑中正确读取多个 Kafka 主题答案

【问题标题】：How to correctly read from multiple Kafka topics in a single Storm topology如何在单个 Storm 拓扑中正确读取多个 Kafka 主题
【发布时间】：2016-11-05 22:18:15
【问题描述】：

我有一个 Storm 拓扑，它必须从多个 Kafka 主题中读取数据并将其输出流式传输到单个 Bolt。

目前我正在使用此代码，它似乎工作正常：-

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()？

【问题讨论】：

标签： apache-kafka apache-storm

【解决方案1】：

可以，您可以多次拨打***Grouping()。

【讨论】：