我试图把Kafka的数据通过风暴在hdfs和Hive。我在和hortonworks一起工作。因此，我有以下结构，正如在许多教程中看到的（稍加修改）(http://henning.kropponline.de/2015/01/24/hive-streaming-with-storm/):

TopologyBuilder builder = new TopologyBuilder();

 builder.setSpout("kafka-spout", kafkaSpout);

 builder.setBolt("hdfs-bolt", hdfsBolt).globalGrouping("kafka-spout");

 builder.setBolt("parse-bolt", new ParseBolt()).globalGrouping("kafka-spout");

 builder.setBolt("hive-bolt", hiveBolt).globalGrouping("parse-bolt");

我将kafka喷口数据直接发送到hdfs-bolt，当我只使用hdfs-bolt时，它就工作了。当我添加parse bolt来解析kafka数据并将其发送到hivebolt时，整个系统都会变得疯狂。即使我只是通过Kafka发送一条消息，这个消息也会被Kafka喷口无限次地复制，并被无限次地写入hdfs。
如果parse bolt中有错误，hdfs bolt不应该仍然正常工作吗？我对这个主题不太熟悉，有人能看出初学者的一个简单错误吗？我很感激你的建议。