smelody

project(':proj') {
    apply plugin: 'application'
    apply plugin: 'shadow'
   
    dependencies {
   
        compile("storm:storm:${storm_version}")
        compile("storm:storm-kafka:${storm_kafka_version}")
   

smelody

 private submitTopology(topologies) {
        Config conf = new Config()
        conf.debug = DEBUG
        conf.put(Config.TOPOLOGY_MAX_SPOUT_PENDING, MAX_SPOUTS_PENDING)
        conf.put(Config.TOPOLOGY_MAX_TASK_PARALLELISM, MAX_TASK_PARALLELISM)
        conf.put(Config.TOPOLOGY_WORKERS, NUM_WORKERS)
        if (LOCAL) {
            LocalCluster localCluster = new LocalCluster()
            topologies.each { name, topology ->
                log.info "Submitting the local cluster for the topology ${name}"

smelody

{
  something: true
}