如何调整Kafka的分区数

调整Kafka分区数分增加和减少两种情况，具体操作如下：

• 增加分区数：
  • 使用命令行工具：通过kafka-topics.sh脚本增加，命令为bin/kafka-topics.sh --alter --topic <topic_name> --partitions <new_partition_count> --bootstrap-server <broker_address>。
  • 使用Kafka Admin API：通过编程方式增加，以Java为例，需初始化AdminClient，创建NewPartitions对象并设置增加的分区数，然后调用alterTopics方法执行变更。
• 减少分区数：Kafka不支持直接减少分区数。若需减少，需创建新主题，将旧主题数据复制到新主题，再删除旧主题，可通过kafka-reassign-partitions.sh工具辅助完成数据复制和主题删除等操作。