二、Kafka 快速入门-linux命令行操作

这就是为了让你熟悉下kafka命令行的使用,实际情况下,不会这样用的


1)查看当前kafka服务器中的所有主题

./kafka-topics.sh --zookeeper 192.168.3.25:2181 --list

clipboard


2)创建 topic

./kafka-topics.sh --zookeeper 192.168.3.25:2181 --create --replication-factor 1 --partitions 1 --topic first

选项说明:

--topic 定义 topic 名

--replication-factor 定义副本数

--partitions 定义分区数

clipboard

查看相应的数据存放的文件夹:

clipboard


3)删除 topic

./kafka-topics.sh --zookeeper 192.168.3.25:2181 --delete --topic first


4)查看某个主题的详情

./kafka-topics.sh --zookeeper 192.168.3.25:2181 --describe --topic first

clipboard


5)修改分区数

./kafka-topics.sh --zookeeper 192.168.3.25:2181 --alter --topic first --partitions 6


6)发送消息

./kafka-console-producer.sh --broker-list 192.168.3.25:9092 --topic first

clipboard


7)消费消息

./kafka-console-consumer.sh --zookeeper 192.168.3.25:2181 --topic first --from-beginning

clipboard

clipboard

(以上命令不在使用)

./kafka-console-consumer.sh --bootstrap-server 192.168.3.25:9092--from-beginning --topic first

原文地址:https://www.cnblogs.com/houchen/p/14002906.html