search

exasol / kafka-connect-jdbc-exasol

Exasol dialect for the Kafka Connect JDBC Connector
Apache License 2.0
10 stars 7 forks source link

"Too few parameters" exception when trying to use delete.enabled #23

Closed dimstunt closed 2 years ago

dimstunt commented 3 years ago

Hello,

I'm trying to run Exasol sink connector with line deletion enabled ("delete.enabled ":"true"). My exasol-sink.json looks this way:

{
  "name": "exasol-sink",
  "config": {
    "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
    "tasks.max": "1",
    "connection.url": "jdbc:exa:exasol-db:8563;schema=CONNECT_TEST",
    "connection.user": "sys",
    "connection.password": "exasol",
    "insert.mode": "upsert",
    "auto.create": "true",
    "auto.evolve": "true",
    "topics": "old_table",
    "table.name.format": "${topic}",
    "pk.mode": "record_key",
    "pk.fields": "id",
    "db.timezone": "Europe/Moscow",
    "offed_____quote.sql.identifiers": "never",
    "delete.enabled": "true"
  }
}

When checking the status after creation, I get this exception in docker log's message:

[2021-08-23 21:33:12,977] INFO Attempting to open connection #1 to Exasol (io.confluent.connect.jdbc.util.CachedConnectionProvider)
[2021-08-23 21:33:13,006] INFO JdbcDbWriter Connected (io.confluent.connect.jdbc.sink.JdbcDbWriter)
[2021-08-23 21:33:13,066] INFO Checking Exasol dialect for existence of TABLE "new_table" (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect)
[2021-08-23 21:33:13,070] INFO Using Exasol dialect TABLE "new_table" absent (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect)
[2021-08-23 21:33:13,070] INFO Creating table with sql: CREATE TABLE "new_table" (
"id" DECIMAL(19,0) NOT NULL,
"name" CLOB NULL,
"email" CLOB NULL,
"department" CLOB NULL,
PRIMARY KEY("id")) (io.confluent.connect.jdbc.sink.DbStructure)
[2021-08-23 21:33:13,080] INFO Checking Exasol dialect for existence of TABLE "new_table" (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect)
[2021-08-23 21:33:13,080] INFO Using Exasol dialect TABLE "new_table" present (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect)
[2021-08-23 21:33:13,084] INFO Checking Exasol dialect for type of TABLE "new_table" (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect)
[2021-08-23 21:33:13,085] INFO Setting metadata for table "new_table" to Table{name='"new_table"', type=TABLE columns=[Column{'name', isPrimaryKey=false, allowsNull=true, sqlType=VARCHAR}, Column{'email', isPrimaryKey=false, allowsNull=true, sqlType=VARCHAR}, Column{'id', isPrimaryKey=true, allowsNull=false, sqlType=DECIMAL}, Column{'department', isPrimaryKey=false, allowsNull=true, sqlType=VARCHAR}]} (io.confluent.connect.jdbc.util.TableDefinitions)
[2021-08-23 21:33:13,100] WARN Write of 1 records failed, remainingRetries=1 (io.confluent.connect.jdbc.sink.JdbcSinkTask)
java.sql.SQLException: Too few parameters for statement. (Session: 1708921342399741952)
    at com.exasol.jdbc.ExceptionFactory.createSQLException(ExceptionFactory.java:242)
    at com.exasol.jdbc.EXASQLException.getSQLExceptionIntern(EXASQLException.java:50)
    at com.exasol.jdbc.AbstractEXAPreparedStatement.execute(AbstractEXAPreparedStatement.java:221)
    at com.exasol.jdbc.AbstractEXAPreparedStatement.executeUpdate(AbstractEXAPreparedStatement.java:421)
    at com.exasol.jdbc.AbstractEXAPreparedStatement.executeBatch(AbstractEXAPreparedStatement.java:182)
    at io.confluent.connect.jdbc.sink.BufferedRecords.executeDeletes(BufferedRecords.java:234)
    at io.confluent.connect.jdbc.sink.BufferedRecords.flush(BufferedRecords.java:188)
    at io.confluent.connect.jdbc.sink.JdbcDbWriter.write(JdbcDbWriter.java:72)
    at io.confluent.connect.jdbc.sink.JdbcSinkTask.put(JdbcSinkTask.java:75)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:563)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:326)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:229)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:201)
    at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185)
    at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235)
    at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
    at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
    at java.base/java.lang.Thread.run(Thread.java:834)
[2021-08-23 21:33:13,100] INFO Closing connection #1 to Exasol (io.confluent.connect.jdbc.util.CachedConnectionProvider)
[2021-08-23 21:33:13,102] INFO Initializing writer using SQL dialect: ExasolDatabaseDialect (io.confluent.connect.jdbc.sink.JdbcSinkTask)
[2021-08-23 21:33:13,102] ERROR WorkerSinkTask{id=exasol-sink-0} RetriableException from SinkTask: (org.apache.kafka.connect.runtime.WorkerSinkTask)
org.apache.kafka.connect.errors.RetriableException: java.sql.SQLException: Exception chain:
java.sql.SQLException: Too few parameters for statement. (Session: 1708921342399741952)

    at io.confluent.connect.jdbc.sink.JdbcSinkTask.put(JdbcSinkTask.java:107)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:563)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:326)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:229)
    at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:201)
    at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185)
    at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235)
    at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
    at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
    at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: java.sql.SQLException: Exception chain:
java.sql.SQLException: Too few parameters for statement. (Session: 1708921342399741952)

    at io.confluent.connect.jdbc.sink.JdbcSinkTask.put(JdbcSinkTask.java:89)
    ... 11 more

In EXA_STATISTICS.EXA_DBA_AUDIT_SQL I see this:

+-------------------+-------+-------------+-------------+--------+-------------------+-------------------+----+----------------+----------------------+--------+---------+---------------+-------------------+----------------+--------------------+---------------+-------------------+----------------+--------------------+----------------+--------------------+-----------------+---------------------+---+-------+----------+---------------------------------+------------+------------------+-----+---------+---------+--------------+------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|SESSION_ID         |STMT_ID|COMMAND_NAME |COMMAND_CLASS|DURATION|START_TIME         |STOP_TIME          |CPU |TEMP_DB_RAM_PEAK|PERSISTENT_DB_RAM_PEAK|HDD_READ|HDD_WRITE|LOCAL_READ_SIZE|LOCAL_READ_DURATION|LOCAL_WRITE_SIZE|LOCAL_WRITE_DURATION|CACHE_READ_SIZE|CACHE_READ_DURATION|CACHE_WRITE_SIZE|CACHE_WRITE_DURATION|REMOTE_READ_SIZE|REMOTE_READ_DURATION|REMOTE_WRITE_SIZE|REMOTE_WRITE_DURATION|NET|SUCCESS|ERROR_CODE|ERROR_TEXT                       |SCOPE_SCHEMA|CONSUMER_GROUP    |NICE |RESOURCES|ROW_COUNT|EXECUTION_MODE|CLUSTER_NAME|SQL_TEXT                                                                                                                                                                                                                                                                                                                                                                                                        |
+-------------------+-------+-------------+-------------+--------+-------------------+-------------------+----+----------------+----------------------+--------+---------+---------------+-------------------+----------------+--------------------+---------------+-------------------+----------------+--------------------+----------------+--------------------+-----------------+---------------------+---+-------+----------+---------------------------------+------------+------------------+-----+---------+---------+--------------+------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|1708921345677131776|1      |CREATE TABLE |DDL          |0.005   |2021-08-23 23:33:16|2021-08-23 23:33:16|14.7|11.0            |0.8                   |0.0     |NULL     |0.0            |0.000              |0.0             |0.000               |0.0            |0.000              |0.0             |0.000               |0.0             |0.000               |0.0              |0.000                |0.0|true   |NULL      |NULL                             |CONNECT_TEST|SYS_CONSUMER_GROUP|false|100      |0        |EXECUTE       |MAIN        |CREATE TABLE "new_table" (                                                                                                                                                                                                                                                                                                                                                                                      |
|1708921345677131776|2      |MERGE        |DML          |0.004   |2021-08-23 23:33:16|2021-08-23 23:33:16|19.4|11.1            |0.8                   |0.0     |NULL     |0.0            |0.000              |0.0             |0.000               |0.0            |0.000              |0.0             |0.000               |0.0             |0.000               |0.0              |0.000                |0.0|true   |NULL      |NULL                             |CONNECT_TEST|SYS_CONSUMER_GROUP|false|100      |0        |PREPARE       |MAIN        |MERGE INTO "new_table" AS target USING (SELECT ? AS "id", ? AS "name", ? AS "email", ? AS "department") AS incoming ON (target."id"=incoming."id") WHEN MATCHED THEN UPDATE SET "name"=incoming."name","email"=incoming."email","department"=incoming."department" WHEN NOT MATCHED THEN INSERT ("name","email","department","id") VALUES (incoming."name",incoming."email",incoming."department",incoming."id")|
|1708921345677131776|3      |DELETE       |DML          |0.001   |2021-08-23 23:33:16|2021-08-23 23:33:16|24.5|11.1            |0.8                   |0.0     |NULL     |0.0            |0.000              |0.0             |0.000               |0.0            |0.000              |0.0             |0.000               |0.0             |0.000               |0.0              |0.000                |0.0|true   |NULL      |NULL                             |CONNECT_TEST|SYS_CONSUMER_GROUP|false|100      |0        |PREPARE       |MAIN        |DELETE FROM "new_table" WHERE "id" = ?                                                                                                                                                                                                                                                                                                                                                                          |
|1708921345677131776|4      |MERGE        |DML          |0.016   |2021-08-23 23:33:16|2021-08-23 23:33:16|19.7|14.0            |0.8                   |0.0     |NULL     |0.0            |0.000              |0.0             |0.000               |0.0            |0.000              |0.0             |0.000               |0.0             |0.000               |0.0              |0.000                |0.0|true   |NULL      |NULL                             |CONNECT_TEST|SYS_CONSUMER_GROUP|false|100      |1        |EXECUTE       |MAIN        |MERGE INTO "new_table" AS target USING (SELECT ? AS "id", ? AS "name", ? AS "email", ? AS "department") AS incoming ON (target."id"=incoming."id") WHEN MATCHED THEN UPDATE SET "name"=incoming."name","email"=incoming."email","department"=incoming."department" WHEN NOT MATCHED THEN INSERT ("name","email","department","id") VALUES (incoming."name",incoming."email",incoming."department",incoming."id")|
|1708921345677131776|5      |NOT SPECIFIED|UNKNOWN      |0.000   |2021-08-23 23:33:16|2021-08-23 23:33:16|24.1|12.1            |0.8                   |0.0     |NULL     |0.0            |0.000              |0.0             |0.000               |0.0            |0.000              |0.0             |0.000               |0.0             |0.000               |0.0              |0.000                |0.0|false  |XQ014     |Too few parameters for statement.|CONNECT_TEST|SYS_CONSUMER_GROUP|false|100      |NULL     |EXECUTE       |MAIN        |NULL                                                                                                                                                                                                                                                                                                                                                                                                            |
|1708921345677131776|6      |ROLLBACK     |TRANSACTION  |0.027   |2021-08-23 23:33:16|2021-08-23 23:33:16|1.8 |12.0            |0.0                   |0.0     |NULL     |0.0            |0.000              |0.0             |0.000               |0.0            |0.000              |0.0             |0.000               |0.0             |0.000               |0.0              |0.000                |0.0|true   |NULL      |NULL                             |CONNECT_TEST|SYS_CONSUMER_GROUP|false|NULL     |0        |EXECUTE       |MAIN        |ROLLBACK /* AUTO */                                                                                                                                                                                                                                                                                                                                                                                             |
+-------------------+-------+-------------+-------------+--------+-------------------+-------------------+----+----------------+----------------------+--------+---------+---------------+-------------------+----------------+--------------------+---------------+-------------------+----------------+--------------------+----------------+--------------------+-----------------+---------------------+---+-------+----------+---------------------------------+------------+------------------+-----+---------+---------+--------------+------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

But everything works when I turn off delete.enabled.

[2021-08-23 21:35:48,617] INFO Attempting to open connection #1 to Exasol (io.confluent.connect.jdbc.util.CachedConnectionProvider)
[2021-08-23 21:35:48,645] INFO JdbcDbWriter Connected (io.confluent.connect.jdbc.sink.JdbcDbWriter)
[2021-08-23 21:35:48,699] INFO Checking Exasol dialect for existence of TABLE "new_table" (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect)
[2021-08-23 21:35:48,702] INFO Using Exasol dialect TABLE "new_table" absent (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect)
[2021-08-23 21:35:48,702] INFO Creating table with sql: CREATE TABLE "new_table" (
"id" DECIMAL(19,0) NOT NULL,
"name" CLOB NULL,
"email" CLOB NULL,
"department" CLOB NULL,
PRIMARY KEY("id")) (io.confluent.connect.jdbc.sink.DbStructure)
[2021-08-23 21:35:48,711] INFO Checking Exasol dialect for existence of TABLE "new_table" (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect)
[2021-08-23 21:35:48,712] INFO Using Exasol dialect TABLE "new_table" present (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect)
[2021-08-23 21:35:48,715] INFO Checking Exasol dialect for type of TABLE "new_table" (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect)
[2021-08-23 21:35:48,717] INFO Setting metadata for table "new_table" to Table{name='"new_table"', type=TABLE columns=[Column{'name', isPrimaryKey=false, allowsNull=true, sqlType=VARCHAR}, Column{'email', isPrimaryKey=false, allowsNull=true, sqlType=VARCHAR}, Column{'id', isPrimaryKey=true, allowsNull=false, sqlType=DECIMAL}, Column{'department', isPrimaryKey=false, allowsNull=true, sqlType=VARCHAR}]} (io.confluent.connect.jdbc.util.TableDefinitions)
[2021-08-23 21:35:48,737] INFO UPSERT records:1 , but no count of the number of rows it affected is available (io.confluent.connect.jdbc.sink.BufferedRecords)
[2021-08-23 21:35:51,871] INFO WorkerSourceTask{id=mysql-source-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask)
[2021-08-23 21:35:51,872] INFO WorkerSourceTask{id=mysql-source-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask)
[2021-08-23 21:36:27,242] INFO AbstractConfig values:
 (org.apache.kafka.common.config.AbstractConfig)
[2021-08-23 21:36:45,521] INFO WorkerSinkTask{id=exasol-sink-0} Committing offsets asynchronously using sequence number 1: {new_table-0=OffsetAndMetadata{offset=1, leaderEpoch=null, metadata=''}} (org.apache.kafka.connect.runtime.WorkerSinkTask)
[2021-08-23 21:36:51,829] INFO WorkerSourceTask{id=mysql-source-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask)
[2021-08-23 21:36:51,829] INFO WorkerSourceTask{id=mysql-source-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask)

In EXA_STATISTICS.EXA_DBA_AUDIT_SQL I see this:

+-------------------+-------+------------+-------------+--------+-------------------+-------------------+----+----------------+----------------------+--------+---------+---------------+-------------------+----------------+--------------------+---------------+-------------------+----------------+--------------------+----------------+--------------------+-----------------+---------------------+---+-------+----------+----------+------------+------------------+-----+---------+---------+--------------+------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|SESSION_ID         |STMT_ID|COMMAND_NAME|COMMAND_CLASS|DURATION|START_TIME         |STOP_TIME          |CPU |TEMP_DB_RAM_PEAK|PERSISTENT_DB_RAM_PEAK|HDD_READ|HDD_WRITE|LOCAL_READ_SIZE|LOCAL_READ_DURATION|LOCAL_WRITE_SIZE|LOCAL_WRITE_DURATION|CACHE_READ_SIZE|CACHE_READ_DURATION|CACHE_WRITE_SIZE|CACHE_WRITE_DURATION|REMOTE_READ_SIZE|REMOTE_READ_DURATION|REMOTE_WRITE_SIZE|REMOTE_WRITE_DURATION|NET|SUCCESS|ERROR_CODE|ERROR_TEXT|SCOPE_SCHEMA|CONSUMER_GROUP    |NICE |RESOURCES|ROW_COUNT|EXECUTION_MODE|CLUSTER_NAME|SQL_TEXT                                                                                                                                                                                                                                                                                                                                                                                                        |
+-------------------+-------+------------+-------------+--------+-------------------+-------------------+----+----------------+----------------------+--------+---------+---------------+-------------------+----------------+--------------------+---------------+-------------------+----------------+--------------------+----------------+--------------------+-----------------+---------------------+---+-------+----------+----------+------------+------------------+-----+---------+---------+--------------+------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|1708921505595588608|1      |CREATE TABLE|DDL          |0.006   |2021-08-23 23:35:48|2021-08-23 23:35:48|16.7|10.9            |0.8                   |0.0     |NULL     |0.0            |0.000              |0.0             |0.000               |0.0            |0.000              |0.0             |0.000               |0.0             |0.000               |0.0              |0.000                |0.0|true   |NULL      |NULL      |CONNECT_TEST|SYS_CONSUMER_GROUP|false|100      |0        |EXECUTE       |MAIN        |CREATE TABLE "new_table" (                                                                                                                                                                                                                                                                                                                                                                                      |
|1708921505595588608|2      |MERGE       |DML          |0.003   |2021-08-23 23:35:48|2021-08-23 23:35:48|24.1|10.9            |0.8                   |0.0     |NULL     |0.0            |0.000              |0.0             |0.000               |0.0            |0.000              |0.0             |0.000               |0.0             |0.000               |0.0              |0.000                |0.0|true   |NULL      |NULL      |CONNECT_TEST|SYS_CONSUMER_GROUP|false|100      |0        |PREPARE       |MAIN        |MERGE INTO "new_table" AS target USING (SELECT ? AS "id", ? AS "name", ? AS "email", ? AS "department") AS incoming ON (target."id"=incoming."id") WHEN MATCHED THEN UPDATE SET "name"=incoming."name","email"=incoming."email","department"=incoming."department" WHEN NOT MATCHED THEN INSERT ("name","email","department","id") VALUES (incoming."name",incoming."email",incoming."department",incoming."id")|
|1708921505595588608|3      |MERGE       |DML          |0.008   |2021-08-23 23:35:48|2021-08-23 23:35:48|21.0|11.1            |0.8                   |0.0     |NULL     |0.0            |0.000              |0.0             |0.000               |0.0            |0.000              |0.0             |0.000               |0.0             |0.000               |0.0              |0.000                |0.0|true   |NULL      |NULL      |CONNECT_TEST|SYS_CONSUMER_GROUP|false|100      |1        |EXECUTE       |MAIN        |MERGE INTO "new_table" AS target USING (SELECT ? AS "id", ? AS "name", ? AS "email", ? AS "department") AS incoming ON (target."id"=incoming."id") WHEN MATCHED THEN UPDATE SET "name"=incoming."name","email"=incoming."email","department"=incoming."department" WHEN NOT MATCHED THEN INSERT ("name","email","department","id") VALUES (incoming."name",incoming."email",incoming."department",incoming."id")|
|1708921505595588608|4      |COMMIT      |TRANSACTION  |0.056   |2021-08-23 23:35:48|2021-08-23 23:35:48|6.3 |10.9            |0.0                   |0.0     |0.6      |0.0            |0.000              |0.0             |0.003               |0.0            |0.000              |0.0             |0.000               |0.0             |0.000               |0.0              |0.000                |0.0|true   |NULL      |NULL      |CONNECT_TEST|SYS_CONSUMER_GROUP|false|NULL     |0        |EXECUTE       |MAIN        |/*EXAConnection.commit()*/ commit;                                                                                                                                                                                                                                                                                                                                                                              |
+-------------------+-------+------------+-------------+--------+-------------------+-------------------+----+----------------+----------------------+--------+---------+---------------+-------------------+----------------+--------------------+---------------+-------------------+----------------+--------------------+----------------+--------------------+-----------------+---------------------+---+-------+----------+----------+------------+------------------+-----+---------+---------+--------------+------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

I do not understand

  1. Why in both cases I get 2 merges when creating a table
  2. How to fix this error

Can somebody help me?

Thanks in advance for your help.

Dmitry

dimstunt commented 3 years ago

@morazow, can you help me, please?

morazow commented 3 years ago

Hello @dimstunt,

Sorry, we somehow missed this issue. I am going to look into it.

morazow commented 3 years ago

Hello @dimstunt,

Thanks for the feedback!

Why in both cases I get 2 merges when creating a table

One of the is a prepare statement, the other is for actual execution. You could observe this on the "execution mode" column of the audit table.

How to fix this error?

I did check a little the code base.

The issue seems to be the deleteStatementBinder is null, because the generic dialect does not override that interface. And we never update the prepared delete statement, but Kafka JDBC runs the statement anyway.

I have added a PR #24, that overrides statement binder. Could you please check it out?

I am going to do some updates (only in tests) then we can merge it soon.

vladoz12 commented 2 years ago

Hello @morazow,

I tried to reproduce the case with kafka-connect-jdbc-exasol-1.0.0.jar built from this branch

But the error was repeated exactly the same. Do I need to send something else, some kind of logs?

morazow commented 2 years ago

This project has been discontinued. Please use exasol/kafka-connector-extension for integration with Apache Kafka.