【kafka连载二】windows测试kafka的消息收发

前提

系统已启动zookeeper和kafka服务，若没有启动请执行以下操作

启动zookeeper

CMD窗口进入zookeeper的bin子目录执行.\zkServer.cmd

启动kafka

CMD窗口进入进入kafka目录并执行.\bin\windows\kafka-server-start.bat .\config\server.properties

创建生产者producer

CMD窗口进入kafka\bin\window子目录，并执行.\kafka-console-producer.bat --broker-list localhost:9092 --topic testtopic(已创建的topic名称) 不用关闭窗口！！！！

创建消费者consumer

CMD窗口进入kafka\bin\window子目录，并执行.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test0909 --from-beginning(可以不添加，加了就读取已存储的消息) 不用关闭窗口！！！！

发布消息和接收消息

在创建者窗口输入任意字符

在消费者窗口查收消息

【kafka连载二】windows测试kafka的消息收发相关推荐

2021年大数据Kafka（二）：❤️Kafka特点总结和架构❤️
全网最详细的大数据Kafka文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录系列历史文章一.Kafka特点总结 kafka特点总结二.Kafka架 ...
python测试rabbitmq的消息收发
send.py #!/usr/bin/env python # -*- coding: UTF-8 -*- import pika import random credentials = pika.P ...
python mq_python测试rabbitmq的消息收发
send.py#!/usr/bin/env python # -*- coding: UTF-8 -*- import pika import random credentials = pika.Pl ...
2021年大数据Kafka（十二）：❤️Kafka配额限速机制❤️
全网最详细的大数据Kafka文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录系列历史文章 Kafka配额限速机制限制producer端的速率限制c ...
windows 安装kafka流程
1.安装jdk 安装地址:www.oracle.com/java/technologies/downloads 下载好后进行安装,基本上一路点击下一步,不要忘记了把安装目录更换一下! 安装好后需要配置 ...
2021年大数据Kafka（三）：❤️Kafka的集群搭建以及shell启动命令脚本编写❤️
全网最详细的大数据Kafka文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录系列历史文章 Kafka的集群搭建以及shell启动命令脚本编写一.搭建 ...
2021年大数据Kafka（十一）：❤️Kafka的消费者负载均衡机制和数据积压问题❤️
全网最详细的大数据Kafka文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录系列历史文章 Kafka的消费者负载均衡机制和数据积压问题一.kafka ...
2021年大数据Kafka（十）：kafka生产者数据分发策略
全网最详细的大数据Kafka文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录系列历史文章生产者数据分发策略策略一:用户指定了partition 策 ...
2021年大数据Kafka（九）：kafka消息存储及查询机制原理
全网最详细的大数据Kafka文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录系列历史文章 kafka消息存储及查询机制原理一.Kafka数据存储机制 ...

【kafka连载二】windows测试kafka的消息收发

【kafka连载二】windows测试kafka的消息收发相关推荐

最新文章

热门文章