我会执行霍顿工厂的拓扑结构来模拟卡车事件。它可以在单个节点（localhost）上完美地工作，但是现在我可以在多个节点上使用它。
事件制作人工作，我可以毫无问题地阅读主题。
但当我运行storm拓扑时，它崩溃了。。。
我唯一的修改是在以下事件中：\u topology.properties：

kafka.zookeeper.host.port=10.0.0.24:2181
# Kafka topic to consume.
kafka.topic=vehicleevent
# Location in ZK for the Kafka spout to store state.
kafka.zkRoot=/vehicle_event_spout
# Kafka Spout Executors.
spout.thread.count=1
# hdfs bolt settings
hdfs.path=/vehicle-events
hdfs.url=hdfs://10.0.0.24:8020
hdfs.file.prefix=vehicleEvents
# data will be moved from hdfs to the hive partition
# on the first write after the 5th minute.
hdfs.file.rotation.time.minutes=5
# hbase bolt settings
hbase.persist.all.events=true
# hive settings
hive.metastore.url=thrift://10.0.0.23:9083
hive.staging.table.name=vehicle_events_text_partition
hive.database.name=default

经过几次尝试，我在topology.java中测试了一个修改：

final Config conf = new Config();
        conf.setDebug(true);
        conf.put(Config.NIMBUS_HOST, "10.0.0.23");
        conf.put(Config.NIMBUS_THRIFT_PORT, 6627);
        conf.put(Config.STORM_ZOOKEEPER_PORT, 2181);
        conf.put(Config.STORM_ZOOKEEPER_SERVERS, Arrays.asList("10.0.0.24", "10.0.0.23"));
        //        StormSubmitter.submitTopology(TOPOLOGY_NAME, conf, builder.createTopology());
        final LocalCluster cluster = new LocalCluster();
        cluster.submitTopology(TOPOLOGY_NAME, conf, builder.createTopology());
        Utils.waitForSeconds(10);
        cluster.killTopology(TOPOLOGY_NAME);
        cluster.shutdown();
    }

如果您有任何建议，非常感谢：）