windos下kafka初探

废话不多说

准备工作

1.去官网下载zookeeper相关的文件  http://zookeeper.apache.org  

2.去网关下载kafka的压缩包 http://kafka.apache.org/downloads

3.修改zookeeper的配置文件

windos下kafka初探

如果没有zoo.cfg文件则拷贝zoo_sample.cfg文件windos下kafka初探

 修改本地存在数据和日志的文件

4.启动zookeeper,在bin目录下启动zkServer.cmd

windos下kafka初探

5.解压kafka后,在kafka目录下cmd ,执行命令 .\bin\windows\kafka-server-start.bat .\config\server.properties

windos下kafka初探

6.创建topic  kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic summer

windos下kafka初探

7.启动生产者  kafka-console-producer.bat --broker-list localhost:9092 --topic summer

windos下kafka初探

8. 启动消费者 kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic summer

(坑0.9前版本的--zookeeper已经过时,请使用bootstrap-server)

windos下kafka初探

9.生产消费 

windos下kafka初探

 windos下kafka初探