linux下的搭建方式1.下载kafka_2.10-0.10.0.0安装kafka 2.我用的的Java1.7.0_513.启动zookeeperbin/zookeeper-server-start.sh config/zookeeper.properties & 4.启动kafka的serverbin/kafka-server-start.sh config/

linux下的搭建方式1.下载kafka_2.10-0.10.0.0安装kafka 2.我用的的Java1.7.0_513.启动zookeeperbin/zookeeper-server-start.sh config/zookeeper.properties & 4.启动kafka的serverbin/kafka-server-start.sh config/

1.Error while executing topic command : replication factor: 1 larger than available brokers: 017/04/06 09:47:15 ERROR admin.TopicCommand$: kafka.admin.AdminOperationException: replication factor: 1

前言在WeTest舆情项目中，需要对每天千万级的游戏评论信息进行词频统计，在生产者一端，我们将数据按照每天的拉取时间存入了Kafka当中，而在消费者一端，我们利用了spark streaming从kafka中不断拉取数据进行词频统计。本文首先对spark streaming嵌入kafka的方式进行归纳总结，之后简单阐述Spark streaming+kafka在舆情项目中的应用，最后将自己