docs: public static void main(String[] args) throws AlreadyAliveException, InvalidTopologyException {
      if (args.length < 1) {
        throw new RuntimeException("Specify topology name");
      }
  
      int parallelism = 1;
      if (args.length > 1) {
        parallelism = Integer.parseInt(args[1]);
      }
      TopologyBuilder builder = new TopologyBuilder();
      builder.setSpout("word", new WordSpout(), parallelism);
      builder.setBolt("consumer", new ConsumerBolt(), parallelism)
          .fieldsGrouping("word", new Fields("word"));
      Config conf = new Config();
      conf.setNumWorkers(parallelism);
  
      StormSubmitter.submitTopology(args[0], conf, builder.createTopology());
    }