storm-kafka-0.8-plus-test:Storm-kafka-0.8-plus的简单测试项目

时间:2024-04-17 19:33:15
【文件属性】:

文件名称:storm-kafka-0.8-plus-test:Storm-kafka-0.8-plus的简单测试项目

文件大小:17KB

文件格式:ZIP

更新时间:2024-04-17 19:33:15

Java

风暴卡夫卡0.8加测试 根据以下信息提供的storm-kafka-0.8-plus测试项目: [ ]( ) [ ]( ) [ ]( ) [ ]( ) 还包含尝试基于[Hazelcast]的三叉戟状态的示例实现( ) ##使用环境设置 如果您使用的是Mac,请按照的说明设置docker环境。 安装 安装(以便您可以将拓扑上传到测试集群) 启动测试环境 fig up 启动kafka外壳 start-kafka-shell.sh 在外壳中,创建一个主题 $KAFKA_HOME/bin/kafka-topics.sh --create --topic storm-sentence --partitions 2 --zookeeper $ZK --replication-factor 1 有关更多详细信息和故障排


【文件预览】:
storm-kafka-0.8-plus-test-master
----src()
--------main()
----start-kafka-shell.sh(138B)
----LICENSE(10KB)
----README.md(4KB)
----pom.xml(5KB)
----fig.yml(685B)
----.gitignore(45B)
----destroy-storm.sh(168B)

网友评论