我可以在Kafka Streams中使用处理器api并从一个kafka集群中的主题读取数据并将数据管道传输到另一个kafka集群中的kafka主题吗?
使用处理器api是可行的吗?我知道,Stream DSL无法实现!
Kafka Streams无法做到这一点。它仅适用于单个群集。
要跨群集复制数据,您需要使用MirrorMaker或其中一个可用的复制器工具,例如Kafka source connector。