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

问题描述

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

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

标签： jdbcapache-kafkaapache-kafka-connect

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

如果您在分布式模式下运行 Connect，您会将单独的配置发布到正在运行的 REST API，每个连接器仍然只有一个查询。

例如

connect-distributed connect-distributed.properties 
curl -X POST localhost:8083/connectors -d@config1.json
curl -X POST localhost:8083/connectors -d@config2.json

否则，独立模式采用空格分隔的属性文件，而不是逗号分隔

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

问题描述

解决方案

推荐阅读