如何在单个Kafka连接器属性文件中配置多个自定义查询

问题描述 投票:0回答:1

当前,我已经在Kafka JDBC源连接器属性文件中配置了单个查询,并且该查询以独立模式运行。如何在单个属性文件中配置多个查询,并为每个查询分配不同的名称,并将其存储在单个主题下。

这是否可行,或者我需要为具有相同主题名称的每个查询构建多个属性文件,并将这些属性文件名添加到执行脚本中,并以逗号分隔。

jdbc apache-kafka apache-kafka-connect
1个回答
0
投票

每个连接器属性只能有一个查询

如果您在分布式模式下运行Connect,则将各个配置发布到正在运行的REST API中

否则,独立模式将使用空格分隔的文件,而不是逗号

© www.soinside.com 2019 - 2024. All rights reserved.