• 欢迎光临~

windows安装启动kafka

开发技术 开发技术 2022-07-22 次浏览

本地安装Kafka

 

 

一、安装方法

 

 

前提 : 本地安装zookeeper

 

 

1、下载 kafka_2.13-2.5.1.tgz 文件 (带src是源码 如:kafka-2.5.1-src.tgz ,不能安装)

 

 

2、解压文件,进入目录,创建 logs文件夹。
进入config目录,打开 server.properties 文件:
注释
#log.dirs=/tmp/kafka-logs
#zookeeper.connect=localhost:2181

 

 

添加配置
log.dirs=E:ProgramFileskafka_2.13-2.5.1logs
zookeeper.connect=127.0.0.1:2181

 

 

3、启动 zookeeper

 

 

4、启动kafka
WIN+R 输入cmd 进入命令行窗口。
进入kafka目录 E:ProgramFileskafka_2.13-2.5.1
输入 .binwindowskafka-server-start.bat .configserver.properties

 

 

二、执行kafka命令

 

 

1、创建主题
命令行进入目录

 

 

C:UsersAdministrator>E:

 

 

E:>cd E:ProgramFileskafka_2.13-2.5.1binwindows

 

 

创建主题
E:ProgramFileskafka_2.13-2.5.1binwindows>kafka-topics.bat --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
Created topic test.

 

 

2、创建生产者消息
E:ProgramFileskafka_2.13-2.5.1binwindows>kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic test

 

 

3、消费者获取消息
E:ProgramFileskafka_2.13-2.5.1binwindows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
kafka-console-consumer.bat –zookeeper localhost:2181 –topic test

 

 

查看所有主题
E:ProgramFileskafka_2.13-2.5.1binwindows>kafka-topics.bat -list -zookeeper localhost:2181

 

 

windows下 kafka启动报错:另一个程序正在使用此文件,进程无法访问

 

 

kafka在windows平台就是有这个BUG,没办法。只能手动删除kafka_2.12-2.5.0kafka-logs里的日志文件重启kafka

程序员灯塔
转载请注明原文链接:windows安装启动kafka
喜欢 (0)