在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