> 文章列表 > windows10开发环境下部署kafka消息服务

windows10开发环境下部署kafka消息服务

windows10开发环境下部署kafka消息服务

  1. 下载kafka,官方地址https://kafka.apache.org/downloads
    百度网盘链接:https://pan.baidu.com/s/1h3iXtfzEIBoajGPId5Dcag?pwd=0000
    提取码:0000
  2. 直接把下载的文件解压到某个盘的根目录,要不然后面的命令就会遇到“命令行过长”的报错;
  3. kafka需要java的支持,所以你的本地环境还得支持java环境;
    windows10开发环境下部署kafka消息服务
  4. 进入解压好的kafka_2.13-3.4.0目录,配置两个文件
    config/server.properties
    zookeeper.properties
# server.properties 34 行
listeners=PLAINTEXT://localhost:9092
# server.properties 62 行
log.dirs=./logs
# zookeeper.properties  16 行,对应kafka的根目录新建data文件夹
dataDir=./data
  1. 开始运行kafaka服务,进入kafka_2.13-3.4.0目录cmd
    windows10开发环境下部署kafka消息服务

5.1、启动zookeeper

# 启动zookeeper
.\\bin\\windows\\zookeeper-server-start.bat .\\config\\zookeeper.properties

保持窗口不要关闭
windows10开发环境下部署kafka消息服务5.2、启动kafka-server,重复第一步打开的新的cmd窗口

# 启动kafka-server
.\\bin\\windows\\kafka-server-start.bat .\\config\\server.properties

保持窗口不要关闭
windows10开发环境下部署kafka消息服务5.3、启动kafka-topics,重复第一步打开的新的cmd窗口

 # 创建一个名为test的topic
.\\bin\\windows\\kafka-topics.bat --create --bootstrap-server  localhost:2181 --replication-factor 1 --partitions 1 --topic test

启动之后,kafka-topics处于等待创建topic状态,一段时间内如果不createTopic,kafka-topics将自动断开。
windows10开发环境下部署kafka消息服务5.4、启动消费者,重复第一步打开的新的cmd窗口

# 启动消费者,并接受test的队列消息
.\\bin\\windows\\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test

windows10开发环境下部署kafka消息服务

5.5、启动生产者,重复第一步打开的新的cmd窗口

# 启动生产者,重复第一步打开的新的cmd窗口
.\\bin\\windows\\kafka-console-producer.bat --broker-list localhost:9092 --topic test

windows10开发环境下部署kafka消息服务此时,就可以在控制台界面输入字符串,回车,对应的消费者控制台就能实时的显示对应的值。