【发布时间】：2018-09-16 08:23:31
【问题描述】：
我可以在 Kafka Streams 中使用处理器 api 并从一个 kafka 集群中的主题读取数据并将数据通过管道传输到另一个 kafka 集群中的 kafka 主题中吗？
使用处理器 api 是否可行？我知道，使用 Stream DSL 是不可能的！
【问题讨论】：
-
如果您自己在处理器中手动创建一个生产者对象是可能的，但如前所述，MirrorMaker 是用于此的官方内置工具
-
如果您创建自己的
KafkaProducer实例，您将需要同步写入以保证至少一次处理。因此，预计性能会下降。这不是推荐的模式。
标签： apache-kafka apache-kafka-streams