KafkaStormES:这是从Kafka中读取并在Elastic Search中建立索引的简单Apache Storm Trident拓扑

[{"title":"（ 10 个子文件 9KB ） KafkaStormES:这是从Kafka中读取并在Elastic Search中建立索引的简单Apache Storm Trident拓扑","children":[{"title":"KafkaStormES-master","children":[{"title":"pom.xml <span style='color:#111;'> 4.59KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"preems","children":[{"title":"kafkaexample","children":[{"title":"functions","children":[{"title":"SplitToNumbers.java <span style='color:#111;'> 737B </span>","children":null,"spread":false},{"title":"ToUpper.java <span style='color:#111;'> 456B </span>","children":null,"spread":false},{"title":"PrepareForES.java <span style='color:#111;'> 1.02KB </span>","children":null,"spread":false}],"spread":true},{"title":"KafkaExampleTopology.java <span style='color:#111;'> 4.15KB </span>","children":null,"spread":false},{"title":"filters","children":[{"title":"ZeroFilter.java <span style='color:#111;'> 370B </span>","children":null,"spread":false},{"title":"PrintFilter.java <span style='color:#111;'> 445B </span>","children":null,"spread":false}],"spread":true},{"title":"state","children":[{"title":"KafkaExampleTridentTupleMapper.java <span style='color:#111;'> 791B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":".gitignore <span style='color:#111;'> 189B </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 1.46KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}]