近来学习 kafka,网上搜的教程好多不好用。在此开一贴记录一下学习过程。推荐官网,是最好的教程 http://kafka.apache.org/quickstart
官网上是linux 环境,我用的是windows 环境。已经安装过jdk
1 下载 kafka ,地址 http://kafka.apache.org/downloads
2 解压,我把它解压到 D:\server\kafka2.12,路径中最好不要有空格
3 修改配置文件 config 目录下的 zookeeper.properties 和 server.properties,
3.1 zookeeper.properties 配置文件修改数据存储目录
dataDir=D:/server/kafka2.12/zookeeper-logs
3.2 server.properties 修改数据存储目录
log.dirs=D:/server/kafka2.12/kafka-logs
在解压目录下,执行以下命令。目录里有 bin 目录
3.3 启动 zookeeper 服务
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
3.4 启动 kafka 服务
bin\windows\kafka-server-start.bat config\server.properties
4 创建一个主题
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1
5 使用如下命令查看创建的主题列表:
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
6 启动生产者:
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test1
7 启动consumer:
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test1 --from-beginning
8 进行测试
在 producer 终端输入字符串,在 consumer 终端可以看到所有的输入