Я пытаюсь использовать kafka connect jdbc для получения данных из DB2 в теме kafka, но пытаюсь запустить приложение, вижу ошибку ниже, которая, я думаю, выполняет настроенный запрос соединителя, и именно поэтому тема kafka таковапусто, ниже полные сведения об ошибке
[2019-05-20 09:56:16,832] ERROR Failed to get current time from DB using query values(CURRENT_TIMESTAMP) on database DB2 (io.confluent.connect.jdbc.util.JdbcUtils:264)
больше трассировки стека исключений ниже
io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier.executeQuery(TimestampIncrementingTableQuerier.java:168)
May 20th 2019, 15:26:16.836 at com.ibm.db2.jcc.am.fp.d(Unknown Source)
May 20th 2019, 15:26:16.836 at com.ibm.db2.jcc.am.fp.c(Unknown Source)
May 20th 2019, 15:26:16.836 at io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier.maybeStartQuery(TimestampIncrementingTableQuerier.java:55)
May 20th 2019, 15:26:16.836 at com.ibm.db2.jcc.am.fp.a(Unknown Source)
May 20th 2019, 15:26:16.836 at com.ibm.db2.jcc.am.kd.a(Unknown Source)
May 20th 2019, 15:26:16.836 at io.confluent.connect.jdbc.util.JdbcUtils.getCurrentTimeOnDB(JdbcUtils.java:255)
May 20th 2019, 15:26:16.836 at io.confluent.connect.jdbc.source.JdbcSourceTask.poll(JdbcSourceTask.java:225)
May 20th 2019, 15:26:16.836 com.ibm.db2.jcc.am.SqlSyntaxErrorException: DB2 SQL Error: SQLCODE=-142, SQLSTATE=42612, SQLERRMC=null, DRIVER=4.19.26
May 20th 2019, 15:26:16.836 at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214)
May 20th 2019, 15:26:16.836 at com.ibm.db2.jcc.t4.vb.i(Unknown Source)
May 20th 2019, 15:26:16.835 at com.ibm.db2.jcc.am.fp.c(Unknown Source)
May 20th 2019, 15:26:16.835 at com.ibm.db2.jcc.am.kd.a(Unknown Source)
May 20th 2019, 15:26:16.835 [2019-05-20 09:56:16,832] ERROR Failed to get current time from DB using query values(CURRENT_TIMESTAMP) on database DB2 (io.confluent.connect.jdbc.util.JdbcUtils:264)
May 20th 2019, 15:26:16.835 at com.ibm.db2.jcc.am.fp.d(Unknown Source)
May 20th 2019, 15:26:16.835 at com.ibm.db2.jcc.am.kd.a(Unknown Source)
May 20th 2019, 15:26:16.835 com.ibm.db2.jcc.am.SqlSyntaxErrorException: DB2 SQL Error: SQLCODE=-142, SQLSTATE=42612, SQLERRMC=null, DRIVER=4.19.26
May 20th 2019, 15:26:16.835 at com.ibm.db2.jcc.t4.p.a(Unknown Source)
May 20th 2019, 15:26:16.835 at com.ibm.db2.jcc.t4.bb.b(Unknown Source)
May 20th 2019, 15:26:16.835 at com.ibm.db2.jcc.am.kd.a(Unknown Source)
May 20th 2019, 15:26:16.835 at com.ibm.db2.jcc.am.fp.a(Unknown Source)
May 20th 2019, 15:26:16.835 at com.ibm.db2.jcc.am.fp.a(Unknown Source)
May 20th 2019, 15:26:16.835 at com.ibm.db2.jcc.t4.bb.h(Unknown Source)
Ниже приведена подробная информация о среде моего приложения
kafka connect jdbc версия: kafka-connect-jdbc-4.1.0.jar и jar-версии Db2:
db2jcc_license_cisuz-1.0.jar db2jcc_license_cu-1.0.jar db2jcc4-4.19.26.jar
это что-то не так с kafkaподключите jdbc, который используете?
я видел эту проблему
https://github.com/confluentinc/kafka-connect-jdbc/issues/211
, поэтому в соответствии с этим мне нужно изменить версию jar kafka-connect-jdbc на более новую версию?если я делаю какие-либо другие файлы, которые мне нужно изменить или добавить в kafka connect для моего приложения или любого другого другого решения?пожалуйста, предложите.