Kafka JDBC Source Connector не читает данные из mysql с помощью SQL-запроса?

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. Вы не можете использовать их вместе.