如何使用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”有了更深的了解，不妨来实际操作一番吧！这里是亿速云网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！