Kafka之动态修改分区partitions数量命令

在Kafka消费组中,要求消费者组中的消费者实例个数不能超过分区的数量,否则会出现部分消费者闲置的情况发生。所以当我们增加消费者数量时,对应可能需要调整分区数量。

动态调整Kafka下某个topic的分区partitions数量命令如下:

bin/kafka-topics.sh --alter --zookeeper localhost:2181 --topic topic-test --partitions 3

上述命令将分区数量调整为3。注意:分区数量只能增加不能减少

附:查看topic详情命令:

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic topic-test
支付宝搜索:344355 领取随机红包

如果文章对您有帮助的话,欢迎老板打赏↑↑↑(请我吃饭😋