Github user srdo commented on a diff in the pull request: https://github.com/apache/storm/pull/2675#discussion_r189455082 --- Diff: examples/storm-rocketmq-examples/src/main/java/org/apache/storm/rocketmq/trident/WordCountTrident.java --- @@ -76,19 +74,16 @@ public static StormTopology buildTopology(String nameserverAddr, String topic){ public static void main(String[] args) throws Exception { Config conf = new Config(); conf.setMaxSpoutPending(5); - if (args.length == 2) { - try (LocalCluster cluster = new LocalCluster(); - LocalTopology topo = cluster.submitTopology("wordCounter", conf, buildTopology(args[0], args[1]));) { - Thread.sleep(60 * 1000); + conf.setNumWorkers(3); + + String topologyName = "wordCounter"; + if (args.length < 2) { + System.out.println("Usage: WordCountTopology <nameserver addr> <topic> [topology name]"); --- End diff -- Nit: Should be WordCountTrident
---