Kafka 流处理器 API 使用情况

Question

我可以在 Kafka Streams 中使用处理器 api 并从一个 kafka 集群中的主题读取数据并将数据通过管道传输到另一个 kafka 集群中的 kafka 主题吗？

使用处理器 api 可以做到吗？我知道，使用 Stream DSL 是不可能的！

Answer 1

Kafka Streams 无法做到这一点。它仅适用于单个集群。

要跨集群复制数据，您需要使用 MirrorMaker or one of the available replicator tools, for example a Kafka source connector。