回顾：

KAFKA集群搭建:

参考百度文章，搭建KAFKA本地集群。

 

这里要注意一个坑：

kafka的config/server.properties文件中的broker.id要和kafka-logs/meta.properties里面的broker.id一致，而kafka-logs/meta.properties是在第一次运行kafka之后生成的。如果不一致，我们可以修改为一致，再启动kafka，如果我们部署kafka集群，是复制粘贴多个kafka文件夹出来的，那就记得一定要改。

启动

.\bin\windows\kafka-server-start.bat .\config\server.properties

创建主题

cmd进入 bin/windows文件夹:运行命令 kafka-topics.bat --create --zookeeper 127.0.0.1:2180,127.0.0.1:2181,127.0.0.1:2182 --replication-factor 2 --partitions 2 --topic mytopic 指令说明:  –create 指定创建topic动作  --zookeeper 指定kafka连接zk的连接url，该值和server.properties文件中的配置项{zookeeper.connect}一样  –replication-factor：指定每个分区的复制因子个数，默认1个  –partitions：指定当前创建的kafka分区数量，默认为1个  –topic:设置主题名字  2.查看主题状态  cmd进入 bin/windows文件夹:运行命令 

kafka-topics.bat --describe --zookeeper 127.0.0.1:2180,127.0.0.1:2181,127.0.0.1:2182 --topic mytopic 

结果信息字段含义: 

1 Partition： 分区  2 Leader ： 负责读写指定分区的节点  3 Replicas ： 复制该分区log的节点列表  4 Isr ： “in-sync” replicas，当前活跃的副本列表（是一个子集），并且可能成为Leader