一、下载安装zookeeper:https://downloads.apache.org/zookeeper
本次使用kafka_2.12-2.8.1.tgz内置zookeeper服务,以下zookeeper安装可以忽略!!!
解压:
修改配置文件:
修改zoo.cfg内容:
启动:
测试:
二.下载kafka安装包安装及配置kafka:
kafka官网下载链接: https://kafka.apache.org/downloads.html
4.3.修改配置文件
4.3.1.kafka_2.12-3.2.1\config\zookeeper.propertis
4.3.2.kafka_2.12-3.2.1\config\server.properties
三.启动kafka服务
本次使用kafka_2.12-2.8.1.tgz内置zookeeper服务,kafka单机版服务,单独的zookeeper服务不需要启动,以上启动zookeeper服务的环节可以忽略。
先启动kafka内置的zookeeper服务!!!!!
在kafka根目录下打开cmd或者PowerShell输入命令
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
成功页面
页面不要关!!!
再启动kafka服务!!!
在kafka根目录下打开cmd或者PowerShell输入命令
.\bin\windows\kafka-server-start.bat .\config\server.properties
成功页面
页面不要关!!!
4.6.创建一个名为 test3 的tiopic的测试主体 kafka
命令如下:
.\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic test 3
成功页面
4.7.创建生产消息的生产者
命令如下:
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test3
页面如下
不要关闭页面!!!
4.8.创建消息消费者接收消息
命令如下:
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test3 --from-beginning
发送端与接收端完整截图:
测试成功!!!
本文转载自: https://blog.csdn.net/weixin_42113716/article/details/132462366
版权归原作者 天空~之城 所有, 如有侵权,请联系我们删除。
版权归原作者 天空~之城 所有, 如有侵权,请联系我们删除。