Соединитель раковины не загружает данные в существующую таблицу Postgres? - PullRequest
Новая
       10

Соединитель раковины не загружает данные в существующую таблицу Postgres?

0 голосов
/ 30 января 2019

Я пытаюсь отправить сообщения из темы кафки (данные в формате avro) в таблицу Postgres.У меня есть все права на создание / вставку / обновление / удаление базы данных / таблицы.В первый раз, когда я запустил соединитель приемника, он автоматически создал таблицу и загрузил все данные, но когда я остановил соединитель и снова попытался загрузить новые данные в существующие данные, он выдает ошибку вроде: 

Caused by: java.sql.SQLException: java.sql.BatchUpdateException: Batch entry 0 INSERT INTO "testing" ("EMPID","TS","EMPNAME","EMPSALARY") VALUES ('abc123','2019:01:23','john',10) ON CONFLICT ("EMPID") DO UPDATE SET "TS"=EXCLUDED."TS","EMPNAME"=EXCLUDED."EMPNAME","EMPSALARY"=EXCLUDED."HITS" was aborted.  Call getNextException to see the cause.
org.postgresql.util.PSQLException: ERROR: relation "testing" does not exist
Position: 13

Вот мойконнектор приемника 

"name": "test",
"config": {
"connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
"tasks.max": "1",
"topics": "emp_data",
"key.converter": "io.confluent.connect.avro.AvroConverter",
"key.converter.schema.registry.url": "http://localhost:8081",
"value.converter": "io.confluent.connect.avro.AvroConverter",
"value.converter.schema.registry.url": "http://localhost:8081",
"connection.url": "jdbc:postgresql://localhost:5432/temp",
"connection.user": "root",
"connection.password": "pwd",
"compact.map.entries": "false",
"insert.mode": "upsert",
"batch.size": "1",
"table.name.format": "testing",
 "pk.mode":"record_value",
 "pk.fields":"EmpID"
"fields.whitelist": "timestamp,empid,empname, empsalary",
"key.ignore": "true",
"auto.create": "false",
"auto.evolve": "true",
"type.connect": "kafka-connect"

Я создал собственную таблицу в базе данных, а затем попытался вставить данные в таблицу, но ничего не произошло.

Любая помощь будет принята с благодарностью!

...