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

觉得内容还不错?打赏个钢镚鼓励鼓励!!👍