kafka jdbc源连接器没有使用sql查询从mysql读取数据？

z9smfwbn 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(334)

我已经在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-

数据库架构