是否可以使用KafkaIO.read为单个管道的两个不同集群指定Kafka引导服务器？

Pipeline pipeline = Pipeline.create(options);

// 为第一个集群设置Kafka引导服务器
String bootstrapServers1 = "kafka1.example.com:9092,kafka2.example.com:9092";
PCollection<String> dataFromCluster1 = pipeline.apply(KafkaIO.<String, String>read()
    .withBootstrapServers(bootstrapServers1)
    .withTopic("topic1")
    .withKeyDeserializer(StringDeserializer.class)
    .withValueDeserializer(StringDeserializer.class)
    .withoutMetadata());

// 为第二个集群设置Kafka引导服务器
String bootstrapServers2 = "kafka3.example.com:9092,kafka4.example.com:9092";
PCollection<String> dataFromCluster2 = pipeline.apply(KafkaIO.<String, String>read()
    .withBootstrapServers(bootstrapServers2)
    .withTopic("topic2")
    .withKeyDeserializer(StringDeserializer.class)
    .withValueDeserializer(StringDeserializer.class)
    .withoutMetadata());

// 将两个集群的数据合并为单个管道
PCollection<String> mergedData = PCollectionList.of(dataFromCluster1).and(dataFromCluster2)
    .apply(Flatten.pCollections());

// 对合并的数据进行处理
mergedData.apply(ParDo.of(new MyDoFn()));

pipeline.run();