topic创建后,可修改分区数、配置等,功能由kafka-topics.sh脚本中alter指令提供。
一、如何增加主题分区数?
例:主题topic-config,分区数1改3
告警信息:"topic有key时(不null),根据key计算分区就有所影响"。1发往一个分区;3原本发分区0,可能发分区1或2。
减少分区报出InvalidPartitionException异常:
二、为什么不支持减少分区?
1、不可靠:
1)存现有分区尾部,时间戳不递增,Spark、Flink需时间戳(事件时间)组件受影响
2)分散插入,复制占用很大资源,复制期间,可用性、顺序性、事务性、状态机切换问题
2、如真要实现,创建分区数小topic,现有复制过去
3、但分区副本数可减少,用kafka-reassign-partition.sh脚本实现
https://mp.weixin.qq.com/s/oMNR2mAffS5pP576o5sbgQ
网友评论