1、官网下载kafka免安装压缩包:https://kafka.apache.org/downloads(建议下载目前最新版3.8.0);
官网下载Kafka安装包
2、解压到本地磁盘目录,并在解压出的kafka根目录下,手动创建kraft模式的数据存储目录:kraft_datas;
手动创建数据存储目录
3、修改配置文件:server.properties,具体修改项如下;
配置文件所在目录
修个配置文件配置项
4、打开cmd,进入kafka目录下的bin/windows目录。通过执行自带脚本来分别生成集群id(生成后这个id要先复制出来给后用)、格式化存储目录
这里用到的两条命令:
1)./kafka-storage.bat random-uuid 用于生成集群id字符串
2)./kafka storage. bat format -t 集群id字符串 -c ../.. /config/kraft/server. properties 用于格式化存储目录
3)执行成功之后,原来手动创建的数据存储目录下会自动创建两个新文件
生成集群ID与格式化存储目录
数据目录下自动生成的新文件
5、完成上述配置和操作之后,就可以试试启动kafka了;通过cmd执行:./kafka-server-start.bat ../../config/kraft/server.properties,如果一切顺利,启动成功后效果如下:
Kafka服务启动成功
6、kafka服务启动之后(原来启动服务的窗口不能关闭),我们可以再新打开两个cmd窗口,通过命令行来创建主题,并模拟生产者、消费者进行消息的发送和接收;
用到的两条命令:
1)./kafka-console-producer.bat --broker-list localhost:9092 --topic kfk_test_topic 用于启动一个生产者生产发送消息,这里会自动创建一个主题:kfk_test_topic,这个主题要与消费者中保持一致,否则消费者接收不到消息
2)./kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kfk_test_topic --from-beginning 用于启动一个消费者接收消费消息
Kafka服务、生产者、消费者
看完是不是觉得很简单了,如果感兴趣,也动手试试吧…[机智][机智][机智]