search

justonedb / kafka-sink-pg-json

Kafka sink connector for streaming messages to PostgreSQL
MIT License
91 stars 31 forks source link

When running Kafka Connect 3.1.1 with Kafk-sink-pg-json, my sink config is:{ "name": "bb1501_possink80", "config": { "connector.class": "com.justone.kafka.sink.pg.json.PostgreSQLSinkConnector", "name": "bb1501_possink80", "topics": "mysql_people2", "db.host":"10.111.134.3", "db.database":"mytestdb", "db.username":"postgres", "db.table":"pgtable1", "db.schema":"$justone$kafka$connect$sink", "db.columns":"id,age,birthday,comment,name,sex", "db.delivery":"synchronized", "db.json.parse":"/@id,/@age,/@birthday,/@comment,/@name,/@sex", "db.buffer.size":"50" } } #8

Open 250690392 opened 7 years ago

250690392 commented 7 years ago

my sink config is: {
"name": "1501_possink80",
"config": {
"connector.class": "com.justone.kafka.sink.pg.json.PostgreSQLSinkConnector",
"name": "1501_possink80",
"topics": "mysql_people2",
"db.host":"10.111.134.3",
"db.database":"mytestdb",
"db.username":"postgres",
"db.table":"pgtable1",
"db.schema":"$justone$kafka$connect$sink",
"db.columns":"id,age,birthday,comment,name,sex",
"db.delivery":"synchronized", "db.json.parse":"/@id,/@age,/@birthday,/@comment,/@name,/@sex",
"db.buffer.size":"50"
} }

java.lang.NoSuchMethodError: org.apache.kafka.connect.sink.SinkTask.close(Ljava/util/Collection;)V at org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask.java:302) at org.apache.kafka.connect.runtime.WorkerSinkTask.closePartitions(WorkerSinkTask.java:435) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:147) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745)