Kafka流处理器API的使用

Question

我能否在Kafka流中使用处理器api，并从一个kafka集群中的某个主题读取数据，并在另一个kafka集群中将数据输送到kafka主题中？

使用处理器api是可行的吗？我知道，这是不可能的流DSL！

Answer 1

这是不可能的卡夫卡流。它只对单个集群起作用。

要跨集群复制数据，您需要使用MirrorMaker或可用的复制器工具之一，例如Kafka源连接器。