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