topic創(chuàng)建后，可修改分區(qū)數(shù)、配置等，功能由kafka-topics.sh腳本中alter指令提供。

一、如何增加主題分區(qū)數(shù)？

例：主題topic-config，分區(qū)數(shù)1改3

告警信息："topic有key時(不null)，根據(jù)key計(jì)算分區(qū)就有所影響"。1發(fā)往一個分區(qū)；3原本發(fā)分區(qū)0,可能發(fā)分區(qū)1或2。

減少分區(qū)報(bào)出InvalidPartitionException異常：

二、為什么不支持減少分區(qū)？

1、不可靠：

? ??1）存現(xiàn)有分區(qū)尾部，時間戳不遞增，Spark、Flink需時間戳(事件時間)組件受影響

? ??2）分散插入，復(fù)制占用很大資源，復(fù)制期間，可用性、順序性、事務(wù)性、狀態(tài)機(jī)切換問題

2、如真要實(shí)現(xiàn)，創(chuàng)建分區(qū)數(shù)小topic，現(xiàn)有復(fù)制過去

3、但分區(qū)副本數(shù)可減少，用kafka-reassign-partition.sh腳本實(shí)現(xiàn)

https://mp.weixin.qq.com/s/oMNR2mAffS5pP576o5sbgQ