是否可以使用java更改现有kafka主题的复制因子？

import java.util.Properties;
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.NewPartitions;
import org.apache.kafka.clients.admin.NewPartitionsIncreaseIsrOptions;
import org.apache.kafka.clients.admin.AlterConfigOp;
import org.apache.kafka.clients.admin.ConfigEntry;
import org.apache.kafka.common.config.ConfigResource;
import org.apache.kafka.common.config.TopicConfig;
import org.apache.kafka.common.TopicPartitionInfo;
import org.apache.kafka.common.errors.UnknownTopicOrPartitionException;

public class KafkaTopicReplicationFactorChanger {

    public static void main(String[] args) {
        // 配置Kafka AdminClient
        Properties props = new Properties();
        props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka-broker1:9092,kafka-broker2:9092");
        AdminClient adminClient = AdminClient.create(props);

        // 指定要更改复制因子的主题和新的复制因子数量
        String topicName = "your_topic_name";
        short newReplicationFactor = 3;

        try {
            // 获取主题的分区信息
            TopicDescription topicDescription = adminClient.describeTopics(Collections.singleton(topicName)).values().get(topicName).get();
            List<NewPartitions> newPartitionsList = new ArrayList<>();

            // 遍历每个分区，创建新的副本分区列表
            for (TopicPartitionInfo partition : topicDescription.partitions()) {
                NewPartitions newPartitions = NewPartitions.increaseTo(partition.partition(), newReplicationFactor);
                newPartitionsList.add(newPartitions);
            }

            // 增加新的副本分区
            adminClient.createPartitions(Collections.singletonMap(topicName, newPartitionsList));

            // 获取主题的当前配置
            ConfigResource topicResource = new ConfigResource(ConfigResource.Type.TOPIC, topicName);
            DescribeConfigsResult describeConfigsResult = adminClient.describeConfigs(Collections.singleton(topicResource));
            Config config = describeConfigsResult.values().get(topicResource).get();
            
            // 修改副本分区的ISR策略为增加分区后的策略（可选）
            ConfigEntry minInSyncReplicasConfig = new ConfigEntry(TopicConfig.MIN_IN_SYNC_REPLICAS_CONFIG, Integer.toString(newReplicationFactor));
            AlterConfigOp alterConfigOp = new AlterConfigOp(minInSyncReplicasConfig, AlterConfigOp.OpType.SET);
            adminClient.incrementalAlterConfigs(Collections.singletonMap(topicResource, Collections.singleton(alterConfigOp)));

            System.out.println("Successfully changed the replication factor of topic " + topicName + " to " + newReplicationFactor);
        } catch (UnknownTopicOrPartitionException e) {
            System.out.println("Topic " + topicName + " does not exist");
        } catch (InterruptedException | ExecutionException e) {
            System.out.println("Failed to change the replication factor of topic " + topicName + ": " + e.getMessage());
        } finally {
            adminClient.close();
        }
    }
}