jstorm-kafka:卡夫卡喷口的jstorm

【文件属性】：

文件名称：jstorm-kafka:卡夫卡喷口的jstorm

文件大小：16KB

文件格式：ZIP

更新时间：2024-06-20 09:27:56

Java

卡夫卡喷口的jstorm 例子： builder.setSpout("kafka-spout", new KafkaSpout(), 1); builder.setBolt("print-bolt", new PrintBolt(), 2).shuffleGrouping("kafka-spout"); public class PrintBolt implements IBasicBolt { private static final Logger logger = LoggerFactory.getLogger(PrintBolt.class); @Override public void declareOutputFields(OutputFieldsDeclarer declarer) { // TODO

【文件预览】：
jstorm-kafka-master
----build.sh(154B)
----src()
--------test()
--------main()
----README.md(1KB)
----pom.xml(4KB)
----.gitignore(63B)