Windows下搭建kafka并通过命令消费
2022/8/15 5:24:32
本文主要是介绍Windows下搭建kafka并通过命令消费,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
一、依赖环境准备
1、检查JDK是否存在且和JVM版本一致,我这里系统是64位,JVM也是64位
2、如果出现以下报错则是JVM不一致
二、安装kafka
1、下载最新版本kafka
kafka官方下载路径: https://kafka.apache.org/downloads.html
我们下载官方推荐的最新版本kafka 3.2.1, Scala 2.13
2、解压到本地,如下图所示
3、分别修改zookpeer和kafka的配置文件 config\zookeeper.properties、config\server.properties
4、根据自己习惯修改zookeeper的data路径到指定位置(不修改也可以,不会影响使用),单机版其他无需修改
5、修改kafka配置文件,advertised.listeners注释打开,并在PLAINTEXT://后加上域名或IP,我这里本机就用localhost了
三、启动zookeeper和kafka
1、启动zoopeeper单机
打开DOS窗口切换路径到 \kafka_2.13-3.2.1\bin\windows下,执行以下命令
zookeeper-server-start.bat ..\..\config\zookeeper.properties
如下图执行此命令,如无报错,则启动成功
2、启动kafka单机
打开DOS窗口切换路径到 \kafka_2.13-3.2.1\bin\windows下,执行以下命令
kafka-server-start.bat ..\..\config\server.properties
3、创建topic
打开DOS窗口切换路径到 \kafka_2.13-3.2.1\bin\windows下,执行以下命令
kafka-topics.bat --create --topic kafka_topic1 --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1 # 可以通过配置使kafka自动创建topic,但生产环境不会这样使用,这里就不作讲解 # kafka-topics.bat 操作topic的脚本 # --create 代表本次操作动作是创建 kafka_topic1 定义的topic名称 # --bootstrap-server 代表kafka的broker地址,多个地址用逗号隔开,这里是单机且本机,使用localhost:9092 # --partitions 1 代表为名称是kafka_topic1的topic创建一个分区 # --replication-factor 1 代表为已创建的分区创建一个备份分区
查看topic命令
打开DOS窗口切换路径到 \kafka_2.13-3.2.1\bin\windows下,执行以下命令
#查看指定topic的命令 kafka-topics.bat --describe --bootstrap-server localhost:9092 --topic kafka_topic1 #查看topic清单 kafka-topics.bat --list --bootstrap-server localhost:9092
四、用命令发布消息和消费消息
1、用命令发布消息
打开DOS窗口切换路径到 \kafka_2.13-3.2.1\bin\windows下,执行以下命令
# 创建producer kafka-console-producer.bat --bootstrap-server localhost:9092 --topic kafka_topic1
运行producer,并发布hello消息
2、用命令消费消息
打开DOS窗口切换路径到 \kafka_2.13-3.2.1\bin\windows下,执行以下命令
# 创建consumer kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka_topic1 --from-beginning # --from-beginning 代表从头开始消费
这里消费到了前面发布的“hello”的消息
到这里就结束了,可以尽情的去发布消息和消费消息了
注意:
kafka启动或者消费消息是报 "java.lang.OutOfMemoryError: Map failed",优先检测系统位数和JVM位数是否一致,见第一步准备环境
这篇关于Windows下搭建kafka并通过命令消费的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-08「布道师系列文章」解析 AutoMQ 对象存储中的文件存储格式
- 2024-05-08「布道师系列文章」小红书黄章衡:AutoMQ Serverless 基石-秒级分区迁移
- 2024-05-08AutoMQ 系统测试体系揭秘
- 2024-03-14AutoMQ 携手阿里云共同发布新一代云原生 Kafka,帮助得物有效压缩 85% Kafka 云支出!
- 2024-02-22kafka partitioner
- 2024-01-24AutoMQ生态集成 - 将数据从 AutoMQ Kafka 导入 RisingWave 数据库
- 2024-01-13消息队列面试题:为什么要使用消息队列?
- 2024-01-08"基于 XHAMQ 的消息队列系统实现"
- 2023-11-24全网最全图解Kafka适用场景
- 2023-09-19RabbitMQ 消息应答