kafka-topics.sh --create --topic order-event \ --partitions 6 --replication-factor 2 \ --bootstrap-server 127.0.0.1:9092 kafka-broker-api-versions.sh --bootstrap-server \ 127.0.0.1:9092
建 topic 报 InvalidReplicationFactorException: Replication factor: 3 larger than available brokers: 2。先别急着动参数,把报错原文和时间点记下来,顺序反了容易白折腾。
原因不复杂,集群里可用的 broker 数量少于请求的副本数,或者部分节点刚下线还在会话超时窗口里,controller 凑不出足够多的副本分配。
「Kafka 副本数配置」确认了原因之后,改动尽量只碰那一处,顺手改的东西后面最容易出问题。改动写完就同步给同事,下一个人踩同一个坑,成本还是你的。
验证用真实数据走一遍,测试数据太干净,边界情况根本碰不到。能分两步做的操作就别合成一步,中间看一眼返回值,出问题好判断。
报错里带路径的,先去看那个路径在不在、权限对不对。同一份配置存在多处的,先确认改的是被加载的那一份。
处理上按这个顺序:先核对 broker 注册数量和实际存活数量是否一致;副本数不要超过节点数 三节点集群给 2 就够了;建 topic 时显式写 replication-factor 不依赖默认值。
改完只确认一件事:topic 创建成功,describe 里每个分区都有两个同步副本。
