赞
踩
#检查所有队列消费情况:
/opt/kafka/bin/kafka-consumer-groups.sh --describe --bootstrap-server kafka1.safedog.cn:9092 --all-groups
#kafka查看某个topic的分区命令:
/opt/kafka/bin/kafka-topics.sh --describe --bootstrap-server kafka.safedog.cn:9092 --topic serverBaseInfo.mysql
#查看所有topic分区列表:
kafka-topics --list --bootstrap-server kafka.safedog.cn:9092
#修改某一个topic分区数量命令:
kafka-topics.sh --bootstrap-server kafka.safedog.cn:9092 --alter --topic serverBaseInfo.mysql --partitions 30
得到分区数,分区数/消费服务器数量 得到配置数
如 分区数是30,部署的消费服务器数量是3,则配置数 为30/3得到10。
如 分区数是45,部署的消费服务器数量是5,则配置数 为45/5得到9。
备注:低版本的kafka使用zookeeper修改分区数,报错如下:
使用zookeeper命令修改分区数发现报错,是因为kafka版本过高,该命令已经无法使用,修改为kafka-topics.sh --bootstrap-server kafka.safedog.cn:9092 --alter --topic serverBaseInfo.mysql --partitions 30
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。