Я сделал инкрементную синхронизацию данных с помощью kafka connect.Теперь я хочу добиться того же с пользовательским запросом.Но я получаю ошибку.
Мой файл конфигурации
name=mysql-whitelist-timestamp-source
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:mysql://127.0.0.1:3306/demouser=root&password=root
query=select name from students3 where marks = 10
mode=timestamp table.whitelist=students3
timestamp.column.name=timestamp
topic.prefix=test-mysql-jdbc-
И ошибка ниже:
ОШИБКА WorkerConnector {id = mysql-whitelist-timestamp-source} Ошибка при запуске соединителя (org.apache.kafka.connect.runtime.WorkerConnector: 119) org.apache.kafka.connect.errors.ConnectException: запрос не может быть объединен с параметрами копирования всей таблицы.