嗨，我正在使用apache-storm创建一个拓扑结构，其中我的Spout正在从Kakfa Topic收集数据并将其发送到一个螺栓。
我正在对元组进行一些验证，并再次为其他螺栓发出流。
现在的问题是，我的第二个螺栓，这是使用流的第一个螺栓有一个重载方法prepare(Map<String, Object> map, TopologyContext topologyContext, OutputCollector outputCollector)，这是执行后，让我们说每2秒。
拓扑代码为

topologyBuilder.setBolt("abc",new ValidationBolt()).shuffleGrouping(configurations.SPOUT_ID);

topologyBuilder.setBolt("TEST",new TestBolt()).shuffleGrouping("abc",Utils.VALIDATED_STREAM);

第一个螺栓“abc”的代码为

@Override
    public void execute(Tuple tuple) {
        String document = String.valueOf(tuple.getValue(4));
        if (Utils.isJSONValid(document)) {
            outputCollector.emit(Utils.VALIDATED_STREAM,new Values(document));
        }
    }

    @Override
    public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
        outputFieldsDeclarer.declareStream(Utils.VALIDATED_STREAM,new Fields("document"));
    }

当我寻找的时候我发现

The prepare method is called when the bolt is initialised and is 
similar to the open method in spout. It is called only once for the bolt.
It gets the configuration for the bolt and also the context of the bolt. 
The collector is used to emit or output the tuples from this bolt.

日志Storm topology log的公共要点链接