使用 Kafka Streams 将数据写入外部主题

Question

我想创建一个 Kafka Streams 应用程序，它从内部 Kafka 主题读取数据并写入位于另一个集群上的外部主题。

有什么办法可以写入外部 Kafka 主题吗？如何通过 yaml 文件为此类应用程序提供配置？

Answer 1

Kafka Streams 仅适用于

to()

到 same 集群。

您可以使用 MirrorMaker 等替代工具发送到一个全新的集群。

否则，Flink/Spark可以提供跨集群的Kafka读/写动作。

通过yaml文件提供配置

Kafka Streams 不使用 YAML。例如，Spring Boot 就可以。