参考百度文章,搭建KAFKA本地集群。windows
这里要注意一个坑:url
kafka的config/server.properties文件中的broker.id要和kafka-logs/meta.properties里面的broker.id一致,而kafka-logs/meta.properties是在第一次运行kafka以后生成的。若是不一致,咱们能够修改成一致,再启动kafka,若是咱们部署kafka集群,是复制粘贴多个kafka文件夹出来的,那就记得必定要改。spa
启动
.\bin\windows\kafka-server-start.bat .\config\server.propertiesserver
建立主题
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文件夹:运行命令 blog
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
kafka