新的 Kafka 自带 Zookeeper,所以不需单独安装 Zookeeper。
1、下载
http://kafka.apache.org/downloads
2、安装
解压 kafka_2.11-2.4.1.tgz 文件。
3、启动
在 kafka_2.11-2.4.1 目录下执行启动命令。
首先执行以下命令,启动 zookeeper:
.\bin\windows\kafka-server-start.bat .\config\server.properties
然后执行以下命令,启动 kafka:
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
4、生成与消费
执行消费命令:
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
执行生成命令,并输入数据:
kafka-console-producer --broker-list localhost:9092 --topic test
>hello
>world
这时候消费端会实时显示生产者输入的信息:
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
hello
world