kafka streams不允许使用来自不同kafka群集的源和输出主题创建流。所以下面的代码将不适用于您

streamsBuilder.stream(sourceTopicName).filter(..).to(outputTopicName)

在本例中，它期望outputtopicname与topic sourcetopicname来自同一集群。
作为一种解决方法，为了将消息从另一个集群发送到输出主题，您可以使用另外创建的kafkaproducer with property bootstrap.servers 指向外部集群和 KStream.foreach() 方法。

streamsBuilder.stream(sourceTopicName)
    .filter((key, value) -> ..)
    .foreach((key, value) -> 
        sendMessage(kafkaProducerFromAnotherCluster, destinationTopicName, key, value);

public static void sendMessage(KafkaProducer<String, String> kafkaProducer, 
                               String destinationTopicName, String key, String value) {
    try {
        kafkaProducer.send(new ProducerRecord(destinationTopicName, key, value));
    } catch (RuntimeException ex) {
        log.error(errorMessage, ex);
    }
}

另一个选项是在kafka集群中创建输出主题，该主题将过滤消息，并在两个集群之间设置kafka镜像（因此消息将从一个主题复制到另一个集群的第二个主题）。