调整Kafka分区数分增加和减少两种情况,具体操作如下:
kafka-topics.sh脚本增加,命令为bin/kafka-topics.sh --alter --topic <topic_name> --partitions <new_partition_count> --bootstrap-server <broker_address>。AdminClient,创建NewPartitions对象并设置增加的分区数,然后调用alterTopics方法执行变更。kafka-reassign-partitions.sh工具辅助完成数据复制和主题删除等操作。