【kafka日常操作命令及分区分配】

#检查所有队列消费情况：
/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