文件名称：storm-kafka:Storm-kafka 项目
文件大小：39.93MB
文件格式：ZIP
更新时间：2024-07-20 03:20:48
Java
storm-kafka 说明 Storm与Kafka集成测试框架，依赖这个库： 部分参考： 框架详细介绍可以看这里： 包括： Kafka的Producer test，通过Websocket读取Wikipedia的实时修改数据 Storm的Spout test，订阅Kafka的producer，数据在bolt中处理完成之后再次发送到Kafka中 1.启动zookeeper ./bin/zkServer.sh start 2.启动Kafka nohup ./bin/kafka-server-start.sh ./config/server.properties & 这时候用jps看，会有一个Kafka的进程 3.下载代码 git clone https://github.com/findhy/storm-kafka.git 4.修改KafkaProperties final static S
【文件预览】：
storm-kafka-master
----pom.xml(5KB)
----target()
--------surefire()
--------classes()
--------maven-archiver()
--------storm-kafka-0.1.0-SNAPSHOT-jar-with-dependencies.jar(44.19MB)
--------storm-kafka-0.1.0-SNAPSHOT.jar(15KB)
----.settings()
--------org.eclipse.m2e.core.prefs(86B)
--------org.eclipse.core.resources.prefs(85B)
--------org.eclipse.jdt.core.prefs(778B)
----src()
--------main()
----.project(645B)
----.classpath(351B)
----README.md(2KB)