Kafka之下载、启动、Topic操作、消息发送读取命令

官网:http://kafka.apache.org/

中文文档:https://kafka.apachecn.org/documentation.html

下载地址:https://www.apache.org/dyn/closer.cgi?path=/kafka/2.7.0/kafka_2.13-2.7.0.tgz


Kafka需要ZooKeeper的支持,所以启动Kafka之前需要先启动ZooKeeper,本地没有ZooKeeper环境的话可以使用Kafka打包的脚本进行启动。

启动ZooKeeper(localhost:2181)

bin/zookeeper-server-start.sh config/zookeeper.properties

启动Kafka(localhost:9092)

bin/kafka-server-start.sh config/server.properties


创建一个名为“test”的Topic,1个副本(--replication-factor),1个分区(--partitions)

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看Topic列表

bin/kafka-topics.sh --list --zookeeper localhost:2181

删除Topic(需要在config/server.properties中配置delete.topic.enable=true,否则只是单纯标记topic为删除,继续创建同名topic会提示已经存在)

bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test

查看Topic详情

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test


启动一个命令行producer进行消息的发送

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

启动一个命令行consumer进行消息的读取

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

--from-beginning 指定从开头进行读取,也就是说每次运行上述命令都会打印所有消息,不加参数则只会从启动时刻起开始打印接收到的消息。


支付宝搜索:344355 领取随机红包

如果文章对您有帮助的话,欢迎老板打赏↑↑↑(请我吃饭😋