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*
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*