我正在使用ApacheStorm0.10.0-beta1,并开始将一些拓扑转换为Flux。我决定从一个简单的拓扑开始,从一个Kafka队列中读取并写入一个不同的Kafka队列。我得到了这个错误,我有一个困难的时间找出什么是错的。拓扑yaml文件遵循错误。388 [main] INFO o.a.s.f.p.FluxParser - loading YAML from input stream...
391 [main] INFO o.a.s.f.p.FluxParser - Not pe
我正在使用暴风KafkaSpout: * Creates a configured kafka spout.* @param topicName Topic where the kafka spout subscribes public KafkaSpout getkafkaSpout(String topicName){
return new KafkaSpout