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

编程知识 更新时间:2023-04-12 16:14:53

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/dist/kafka/2.8.1/

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

文件目录是这样子的

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

server.properties
zookeeper.properties

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




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

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

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

输入.\bin\windows\kafka-server-start.bat .\config\server.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.1\bin\windows 下执行
kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test-topic

出现下图表示topic创建成功

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

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

3、我们创建一个消费者
在安装的目录D:\kafka_2.13-2.8.1\bin\windows 打开一个新的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

更多推荐

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

本文发布于:2023-04-10 22:32:00,感谢您对本站的认可!
本文链接:https://www.elefans.com/category/jswz/de737bce40681ac03b7ae8030abd4e4b.html
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。
本文标签:生产者   消费者   消息   主题   kafka

发布评论

评论列表 (有 0 条评论)
草根站长

>www.elefans.com

编程频道|电子爱好者 - 技术资讯及电子产品介绍!

  • 66384文章数
  • 14阅读数
  • 0评论数