kafka+如何处理分区副本数大于已配置的复制因子的情况？

当分区副本数大于已配置的复制因子时，需要先更改副本数再更改复制因子。下面是示例代码：

// 设置主题名称以及分区和副本数量 String topicName = "my_topic"; int numPartitions = 5; int numReplicas = 2;

// 创建一个主题副本分配方案 TopicPartitionReplicaAssignment replicaAssignment = new TopicPartitionReplicaAssignment(topicName, numPartitions);

// 设置副本数为3 replicaAssignment.assignReplicasToBrokers(numReplicas, 3, true);

// 更改复制因子为2 AdminClient adminClient = AdminClient.create(properties); Map<String, NewPartitions> partitionsMap = new HashMap<>(); partitionsMap.put(topicName, NewPartitions.increaseTo(numPartitions, Arrays.asList(new NewPartition(topicName, numReplicas, new ArrayList<>())))); adminClient.createPartitions(partitionsMap).all().get();

// 执行主题分区副本分配 adminClient.createTopics(Arrays.asList(replicaAssignment)).all().get();