1.查询kafka集群中的topic
![](https://img.haomeiwen.com/i16647275/2c15c9e49992fb48.png)
2.创建topic
需要指定分区数量,和副本因子
![](https://img.haomeiwen.com/i16647275/5d41b4f2c49f1f40.png)
3.一台节点console 当做生产者
![](https://img.haomeiwen.com/i16647275/b97965719477164f.png)
4.一台节点console 当做消费者
![](https://img.haomeiwen.com/i16647275/10837d09f07cca58.png)
5.查看topic的详细信息
可以看到0号分区的leader是0号broker,Replicas在0,1,2号broker上 ,leader均衡机制,会按照Isr的顺序来;
![](https://img.haomeiwen.com/i16647275/3cb926daf8b39609.png)
6.删除topic
![](https://img.haomeiwen.com/i16647275/12c4d54aa4fe1b93.png)
需要指定分区数量,和副本因子
可以看到0号分区的leader是0号broker,Replicas在0,1,2号broker上 ,leader均衡机制,会按照Isr的顺序来;
本文标题:Kafka命令
本文链接:https://www.haomeiwen.com/subject/uvthvqtx.html
网友评论