如何使用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