本文主要是介绍Kafka 学习笔记（二）--- topic命令行操作，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
上一篇介绍了kafka的特点，这篇来记录kafka的主要工作方式： 1.创建Topic， 2. 生产者生产 3.消费者消费
首先 创建 一个 test topic， 命令如下：
./kafka-topics.sh --zookeeper 172.28.201.217:2181 --create --topic test --replication-factor 2 --partitions 3这里有两个参数需要注意：
replication-factor： 副本因子， 说明topic的每个分区分别有两个副本
partitions： 分区数， 说明 该topic有三个分区
然后 生产者， 利用 命令行来向topic中生产数据:
./kafka-console-producer.sh --broker-list 172.28.201.211:9092,172.28.201.212:9092,172.28.201.213:9092 --topic test --producer.config ../config/producer.properties输入数据
然后 消费者， 利用 命令行来消费topic中数据:
./kafka-console-consumer.sh --zookeeper 172.24.201.212:2181 --topic test --new-consumer --from-beginning --consumer.config ../config/consumer.properties结果如下
除此外 调试常用的命令行还有
查看 集群里的topic详情
./bin/kafka-topics.sh --zookeeper 10.95.26.27:2181 --describe只是列出所有主题名字
./bin/kafka-topics.sh --zookeeper 10.95.26.27:2181 --list给集群中test主题增加分区数到16
./bin/kafka-topics.sh --zookeeper 10.95.26.27:2181 --alert --topic test --partitions 16删除某个主题
./bin/kafka-topics.sh --zookeeper 10.95.26.27:2181 --delete --topic test查看某个消费群组的消费情况
./kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.16.17.12:9092 --command-config ../config/consumer.properties --describe --group groupid另外 kafka consumer 命令行消费时，加 --from-beginning 会消费历史数据，如果不加则会消费新进入的数据
这篇关于Kafka 学习笔记（二）--- topic命令行操作的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
