我想根据某种条件将主题1的一些数据(日志)从Kafka群集a复制到另一个Kafka群集b。是否可以使用ksql执行此操作?我不想使用mirrormaker,因为我不想复制所有数据和主题。基本上,我要问的是,是否有一种方法可以在with子句的下面命令中配置集群名称和主题名称。
CREATE STREAM INPUT_STREAM (viewtime bigint, userid varchar, pageid varchar) WITH (kafka_topic='pageviews', value_format='DELIMITED');
如果这在ksql中是不可能的,那么还有其他方法可以做到吗。
提前谢谢。
1条答案
按热度按时间xyhw6mcr1#
在ksql属性中,只能连接一个boostrap服务器。
相反,您需要从另一个集群创建mirrormaker/confluent replicator连接器。