Кафка коннектор источника не работает с db2
Когда я запускаю соединитель источника kafka connect на MySQL, все работает нормально, я работаю со стратегией временной метки, проблема возникает, когда я пытаюсь сделать это с другой базой данных, в моем случае я пытаюсь получить информацию из db2 таблица, когда я выполняю свой соединитель, я получаю следующую ошибку:
ERROR Failed to get current time from DB using query select CURRENT_TIMESTAMP; on database DB2 (io.confluent.connect.jdbc.util.JdbcUtils:263)
com.ibm.db2.jcc.am.SqlSyntaxErrorException: DB2 SQL Error: SQLCODE=-104, SQLSTATE=42601, SQLERRMC=<END-OF-STATEMENT>;( CONCAT || / MICROSECONDS MICROSECOND SECONDS SECO, DRIVER=4.21.29
Я думаю, что это не обнаружение базы данных, и она пытается выполнить запрос: выберите CURRENT_TIMESTAMP
И это не работает в db2, поэтому нам нужно указать базу данных, есть ли способ указать класс драйвера или базу данных, которую мы используем?
РЕДАКТИРОВАТЬ
---- Моя конфигурация разъема
{
"name": "test2-conn",
"config":
{
"mode":"timestamp",
"debug":true,
"poll.interval.ms":10000,
"timestamp.delay.interval.ms":60000,
"timestamp.column.name":"LAST_UPDATE_TIME",
"incrementing.column.name":"id",
"connector.class":"io.confluent.connect.jdbc.JdbcSourceConnector" ,
"connection.url":"jdbc:db2://url:port/db:currentSchema=schema",
"connection.password":"psswd",
"connection.user":"user",
"table.types":"VIEW",
"table.whitelist":"my_view",
"tasks.max":"1",
"topic.prefix":"gta-tors-platform",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"key.converter":"org.apache.kafka.connect.storage.StringConverter",
"key.converter.schemas.enable":false,
"value.converter.schemas.enable":false,
"transforms":"createKey",
"transforms.createKey.type":"org.apache.kafka.connect.transforms.ValueToKey",
"transforms.createKey.fields":"EMP_NAME"
}
}
Я использую Я использую z/OS DB2 V11.1 в режиме NFM
Спасибо за вашу помощь