一、安装
- kafka 需要java环境;
- kafka 最新版本内置了 zookeeper,所以不需要安装zookeeper;
- 下载kafka最新版本,因为下载的是tgz文件,所以不需要安装,解压到相应的地方就可以了。下载地址:http://kafka.apache.org/downloads(我使用的版本:kafka_2.11-1.1.0)
- bin 目录下放的是启动kafka的文件,conf目录下放的是kafka的各种配置文件。
总结:至此kafka在windows平台上的搭建完成了。
二、使用:
简单测试,查看是否ok。
PS:zookeeper默认端口:2181;生产者默认端口:9092
总结:
简单测试一共五步:
1.启动zookeeper
2.启动kafka
3.创建主题topic
4.启动消费者 customer
5.启动生产者 producer
1.启动zookeeper
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
2.启动kafka
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
3.创建主题topic,并查看
创建命令:
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic wzq
查看命令:
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
4.启动消费者 customer
bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic wzq --from-beginning
5.启动生产者 producer
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic wzq
PS:有五个黑窗口 1.zookeeper服务(不可关闭) 2.kafka服务(不可关闭) 3.创建主题(可关闭) 4.消费者(不可关闭) 5.生产者(不可关闭)。