kafka-storm-cassandra:简单演示

卡夫卡风暴卡桑德拉 用一个简单的例子实时处理 ###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