【消息中间件】kafka启动和配置详细版干货

解压启动zookeeper

.\bin\zkServer

安装kafka

直接放根目录下，否则文件深度过大报错

配置

\conf\zoo.cfg配置

#绝对路径或相对路径
dataDir=G:\\zk\\apache-zookeeper-3.6.2-bin\\data
dataLogDir=G:\\zk\\apache-zookeeper-3.6.2-bin\\log

解压并进入Kafka目录，笔者：D:\Kafka\kafka_2.12-0.11.0.0

进入config目录找到文件server.properties并打开

找到并编辑,

#/表示路径，'\\'反向路劲，
log.dirs=D:\\Kafka\\kafka-logs

#delete日志清除
log.cleaner.enable=true
#配置监听
listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://localhost:9092

启动

安装目录下

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

• 创建主题，也就是会话

\bin\windows目录下打开新的命令行。

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

//bin目录 下执行以下命令

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

• 查看会话

.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

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

• 创建生产者

创建新cmd

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

kafka-console-producer.bat --broker-list localhost:9092 --topic test

• 创建消费者

创建新cmd

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

//

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

建立脚本分别启动zookeeper和kafka

win下后缀为.bat

zstart.bat

.\bin\zkServer
G:\kafka_2.12-2.6.0\bin\zkServer

单独启动

kstart.bat

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

启动加测试kafka.bat

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

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic spring_kafka   --from-beginning

脚本命令

start cmd   //打开新cmd

start (指令) 比如 start ping 172.168.13.1 就会弹出新的窗口,并运行ping命令 start cmd

按顺序执行

@echo off
call 1.exe
call 2.exe
exit

或直接使用ping等待延时

ping 127.0.0.1
ping 127.0.0.2
ping 127.0.0.3