admin 管理员组

文章数量: 886992

1、下载kafka

http://kafka.apache/downloads

2、解压,进入config目录找到文件server.properties并打开

3、找到并编辑log.dirs,修改为本地目录

5、找到并编辑zookeeper.connect=localhost:2181,修改为zookeeper中配置的端口号

Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181

 

6、C:\nonda\program files\kafka_2.12-2.1.0\bin文件夹下的.sh命令脚本是在shell下运行的,此文件夹下还有个 windows文件夹,里面是windows下运行的.bat命令脚本 

7、打开cmd窗口,进入kafka_2.12-2.1.0目录

8、输入并执行以下命令启动kafka:

.\bin\windows\kafka-server-start.bat .\config\server.properties

linux安装流程:https://kafka.apache/quickstart

注:

1. 安装kafka的文件路径不能有空格,如:D:\\Program Files\\kafka,kafka启动时报错,提示找不到或者无法加载类

2. 修改bin\windows\kafka-run-class.bat 文件中%CLASSPATH% ,加""

 

9、启动cmd窗口,进入kafka的bin\windows目录,创建一个主题

kafka-topics.bat --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic my-topic-test

10、查看当前主题列表

kafka-topics.bat --list --zookeeper 127.0.0.1:2181

11、生产消息

kafka-console-producer.bat --broker-list 10.0.0.147:9091 --topic my-topic-test

12、保持生产消息窗口不关闭,另起cmd窗口,进入kafka的bin\windows目录下,消费消息

kafka-console-producer.bat --broker-list 10.0.0.147:9091 --topic my-topic-test

 

此时,在生产消息窗口输入消息,在消费消息窗口就能看到接受的消息了

--from beginning 是从头开始消费,不加则是消费当前正在发送到该topic的消息

topic消息在磁盘中分布情况:  du -sh /data*/zdh/kafka/data/kafka_topic*

本文标签: Windows Kafka