調整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工具輔助完成數據復制和主題刪除等操作。