Storm2-WordCountWithGroupingsAndAck //这里创建了2个spout实例。对于预期的输出,运行分组中的示例。 builder.setSpout(SENTENCE_SPOUT_ID, spout, 2);运行后创建和删除拓扑。在prod中更改以下代码。 cluster.submitTopology(TOPOLOGY_NAME, config, builder.createTopology());等待秒(10); cluster.killTopology(TOPOLOGY_NAME); cluster.shutdown(); checkins.txt和log4j存在于maven项目的资源文件夹中。一旦jaar被创建,它就在类路径中。 -----风