如何使用kafka

本篇内容主要讲解“如何使用kafka”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“如何使用kafka”吧!

网站建设哪家好,找创新互联!专注于网页设计、网站建设、微信开发、微信小程序定制开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了临漳免费建站欢迎大家使用!

启动zookeeper

zookeeper-server-start.bat D:\tcm\soft\kafka_2.11-2.3.1\config\zookeeper.properties

启动kafka

kafka-server-start.bat D:\tcm\soft\kafka_2.11-2.3.1\config\server.properties

通过cmd进入windows命令目录

D:\tcm\soft\kafka_2.11-2.3.1\bin\windows

创建主题

创建一个名为“test”的主题,它只包含一个分区,只有一个副本:

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看主题,

运行list topic命令:

kafka-topics.bat --list --zookeeper localhost:2181

消息生产

发送一些消息

Kafka附带一个命令行客户端,它将从文件或标准输入中获取输入,并将其作为消息发送到Kafka集群。默认情况下,每行将作为单独的消息发送

kafka-console-producer.bat --broker-list localhost:9092 --topic test

消息消费者

Kafka还有一个命令行使用者,它会将消息转储到标准输出

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

到此,相信大家对“如何使用kafka”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!


分享文章:如何使用kafka
分享路径:http://pwwzsj.com/article/jehgdp.html