mysql - Kafka JDBC Source Connector 没有使用 sql 查询从 mysql 读取数据？

Question

我在 MySQL 上创建了一个本地数据库用于测试目的。当我尝试从数据库读取数据时，它读取得很好。当我在连接器配置中使用 SQL 查询时，它只是运行但不从数据库读取任何数据。知道什么可能会导致这种情况吗？

这是我的连接器配置:

name=just-like
acks=0 
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
key.converter=io.confluent.connect.avro.AvroConverter
key.converter.schema.registry.url=http://localhost:8081
value.converter=io.confluent.connect.avro.AvroConverter
value.converter.schema.registry.url=http://localhost:8081
connection.url=jdbc:mysql://localhost:3306/DBtest?user=**&password=**
connection.user=**  
connection.password=**  
table.whitelist=test
mode=timestamp  
timestamp.column.name=createddate  
query= select column_name from table_name  
validate.non.null=False 
topic.prefix=sql-

数据库架构

Answer 1

我们不应将标签 table.whitelist 与自定义查询一起使用。如果您想使用查询标签，我建议删除 table.whitelist 标签。您不能同时使用它们。