kafka manager安装
下载安装包,并解压到你自己指定的目录
进入到/opt/module/kafka-manager-1.3.3.22/conf目录,在application.conf文件中修改kafka-manager.zkhosts
[[email protected] conf]$ vim application.conf
修改为:
kafka-manager.zkhosts="hadoop102:2181,hadoop103:2181,hadoop104:2181"
启动
nohup bin/kafka-manager -Dhttp.port=7456 >/opt/module/kafka-manager-1.3.3.22/start.log 2>&1 &
登录hadoop102:9000页面查看详细信息 和namenode的通讯端口冲突 在启动时修改port
-Dhttp.port=9090
topic leader 第一次创建分布肯定是均匀的 但出现braker宕机又恢复时会出现leader倾斜
最开始的状态会被保存下来 只需要恢复到最开始的状态就可以
处理步骤分两步
重新分配分区 可以所有topic一起操作也可以单独操作每一个topic
查看consumers