1.查询kafka集群中的topic
查看kafka集群topic
2.创建topic
需要指定分区数量,和副本因子
新建to'pi'c
3.一台节点console 当做生产者
node02当作生产者
4.一台节点console 当做消费者
node03当作消费者
5.查看topic的详细信息
可以看到0号分区的leader是0号broker,Replicas在0,1,2号broker上 ,leader均衡机制,会按照Isr的顺序来;
查看topic详细信息
6.删除topic
