目前,我已经在kafka jdbc源连接器属性文件中配置了单查询,它以独立模式运行。如何在单个属性文件中配置多个查询,为每个查询指定不同的名称,并将其存储在单个主题下。这是可行的还是我需要为每个查询构建多个属性文件,使用相同的主题名,并将这些属性文件名添加到执行脚本中,以逗号分隔。
gr8qqesn1#
每个连接器属性只能有一个查询如果在分布式模式下运行connect,则会将各个配置发布到正在运行的restapi,每个连接器仍然只有一个查询。例如
connect-distributed connect-distributed.properties curl -X POST localhost:8083/connectors -d@config1.json curl -X POST localhost:8083/connectors -d@config2.json
否则,独立模式采用空格分隔的属性文件,而不是逗号分隔的
1条答案
按热度按时间gr8qqesn1#
每个连接器属性只能有一个查询
如果在分布式模式下运行connect,则会将各个配置发布到正在运行的restapi,每个连接器仍然只有一个查询。
例如
否则,独立模式采用空格分隔的属性文件,而不是逗号分隔的