1.查询kafka集群中的topic
查看kafka集群topic2.创建topic
需要指定分区数量,和副本因子
新建to'pi'c3.一台节点console 当做生产者
node02当作生产者4.一台节点console 当做消费者
node03当作消费者5.查看topic的详细信息
可以看到0号分区的leader是0号broker,Replicas在0,1,2号broker上 ,leader均衡机制,会按照Isr的顺序来;
查看topic详细信息需要指定分区数量,和副本因子
新建to'pi'c可以看到0号分区的leader是0号broker,Replicas在0,1,2号broker上 ,leader均衡机制,会按照Isr的顺序来;
查看topic详细信息本文标题:Kafka命令
本文链接:https://www.haomeiwen.com/subject/uvthvqtx.html
网友评论