文件名称：kafka-storm-cassandra:简单演示
文件大小：417KB
文件格式：ZIP
更新时间：2024-06-26 12:11:49
Java
卡夫卡风暴卡桑德拉 用一个简单的例子实时处理 ###Kafka 这个设置对我有用： 卡夫卡 0.7.2 sbt 2.9.2 jdk-6 ###Cassandra 安装 Cassandra 2+。 使用以下命令创建一个键空间和一个表。 CREATE KEYSPACE test WITH replication = { ' class ' : ' SimpleStrategy ' , ' replication_factor ' : 1 }; use test; CREATE TABLE logs ( time timestamp , log_level varchar , count int , primary key (log_level, time )); ###Storm 运行 Storm 拓扑。 mvn -e clean compile exec:java -Dexe
【文件预览】：
kafka-storm-cassandra-master
----CassandraWatcher()
--------WebContent()
--------src()
----storm()
--------pom.xml(2KB)
--------src()
----log2kafka.py(1KB)
----example.png(77KB)
----.gitignore(3KB)
----log.py(522B)
----README.md(1KB)
----.gitattributes(483B)