打开DOS窗口切换路径到 \kafka_2.13-3.2.1\bin\windows下,执行以下命令
zookeeper-server-start.bat ..\..\config\zookeeper.properties
如下图执行此命令,如无报错,则启动成功
打开DOS窗口切换路径到 \kafka_2.13-3.2.1\bin\windows下,执行以下命令
kafka-server-start.bat ..\..\config\server.properties
打开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
打开DOS窗口切换路径到 \kafka_2.13-3.2.1\bin\windows下,执行以下命令
# 创建producer kafka-console-producer.bat --bootstrap-server localhost:9092 --topic kafka_topic1
运行producer,并发布hello消息
打开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位数是否一致,见第一步准备环境