是否可以使用 KSQL 将数据从一个 Kafka 集群复制到另一个 Kafka 集群？

Question

我想根据某些条件将主题 TOPIC_1 的一些数据（日志）从 Kafka Cluster A 复制到另一个 Kafka Cluster B .是否可以使用 KSQL 来做到这一点？ 我不想使用 MirrorMaker，因为我不想复制所有数据和主题。基本上我要问的是是否有一种方法可以在 WITH 子句中的以下命令中配置集群名称以及主题名称。

CREATE STREAM INPUT_STREAM (viewtime bigint, userid varchar, pageid varchar) WITH (kafka_topic='pageviews', value_format='DELIMITED');

如果 KSQL 无法做到这一点，是否还有其他方法可以做到这一点。

提前致谢。

Answer 1

在 KSQL 属性中，只能连接一台 boostrap 服务器。

您需要从另一个集群创建一个 MirrorMaker / Confluent Replicator 连接器。