目前，我已经在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，每个连接器仍然只有一个查询。
例如
否则，独立模式采用空格分隔的属性文件，而不是逗号分隔的