栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

windows安装kafka 2.8.1以及创建主题(topic)生产者和消费者消息接收和发送

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

windows安装kafka 2.8.1以及创建主题(topic)生产者和消费者消息接收和发送

windows 安装kafka 2.8.1
电脑上的前置的条件为
1、在电脑上有安装jdk

2、2.8.1中的kafka版本里面有包含了zookeeper,故此本版本不需要安装zookeeper

第一步:到kafka官网上找安装包
我是使用的网址为以下地址:包一定别选错了 kafka_2.13-2.8.1.tgz
http://archive.apache.org/dist/kafka/2.8.1/

第二步 安装+配置
将下载下来的安装包(kafka_2.13-2.8.1.tgz)解压到指定文件夹:如图我是解压到了D盘

文件目录是这样子的

D:kafka_2.13-2.8.1config 文件的目录下你能看到

server.properties
zookeeper.properties

第三步 启动配置卡夫卡
第一步首先要启动 zookeeper 服务




弹出终端,然后输入命令 启动zookeeper命令(一定要先启动zookeeper)
简单的说无论你在安装在那个目录下,这个命令直接在你安装的目录下启动cmd执行该命令;
binwindowszookeeper-server-start.bat configzookeeper.properties

当你看到这个的时候说明你启动成功了,接下来启动kafka程序

同样的操作在安装文件的根目录 cmd 调出终端窗口

输入.binwindowskafka-server-start.bat .configserver.properties


有这个打印的时候说明安装成功了;

停止服务 来个方法 一个直接在启动服务的终端直接CTRL+c就能停止服务;
以上就完成了windows的kafka的安装了。有问题欢迎交流

第四步 测试
1、我们先创建一个topic
创建topic得命令为
kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test-topic
注: 这个命令得注解为
–replication-factor 1 : 表示创建一个通知队列
–partitions 1 :表示创建一个分片
–topic 主题名称 :该命令中创建了一个主题名称为 test-topic得主题
命令一定是要在 安装的目录D:kafka_2.13-2.8.1binwindows 下执行
kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test-topic

出现下图表示topic创建成功

2、我们创建一个生产者
同样的道理到,安装的目录D:kafka_2.13-2.8.1binwindows 下执行
kafka-console-producer.bat --broker-list localhost:9092 --topic test-topic
–broker-list:表示消息创建的是时候是list形式

如下图所示表示创建生成者成功

3、我们创建一个消费者
在安装的目录D:kafka_2.13-2.8.1binwindows 打开一个新的CMD页面
执行命令 kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic
如下图所示表示成功


上图所示是两个CMD窗口。到这里整个2.8.1的kafka就安装完成了,并能成功的发送消息!!若有疑问欢迎留言交流

创建主题 test-topic
kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test-topic

启动消费者
kafka-console-producer.bat --broker-list localhost:9092 --topic test-topic

启动生产者
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic

查看消费组
kafka-consumer-groups.bat --bootstrap-server localhost:9092 --list

查看主题命令
kafka-topics.bat --list --bootstrap-server localhost:9092

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/777571.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号