Ошибка синтаксиса JDBC-приемника коннектора kafka в конце - PullRequest
Новая
       23

Ошибка синтаксиса JDBC-приемника коннектора kafka в конце

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

У меня проблема с JDBC-стоком с этой аркой.

postgres1 ---> kafka ---> postgres2

производитель работает нормально, ноу потребителя есть ошибка:

connect_1 |org.apache.kafka.connect.errors.SET был прерван: ОШИБКА: синтаксическая ошибка в конце ввода connect_1 |
Position: 77 Вызовите getNextException, чтобы увидеть другие ошибки в пакете.

это мой источник. Json 

{
"name": "src-table",
"config": {
    "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
    "tasks.max": "1",
    "database.hostname": "postgres1_container",
    "database.port": "5432",
    "database.user": "postgres",
    "database.password": "postgres",
    "database.dbname": "postgres",
    "database.whitelist": "postgres",
    "database.server.name": "postgres1",
    "database.history.kafka.bootstrap.servers": "kafka:9092",
    "database.history.kafka.topic": "schema-changes.inventory",
    "transforms": "route",
    "transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter",
    "transforms.route.regex": "([^.]+)\\.([^.]+)\\.([^.]+)",
    "transforms.route.replacement": "$3"
}

и это мой jdbc-sink.json 

{
    "name": "jdbc-sink",
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
        "tasks.max": "1",
        "topics": "customers",
        "connection.url": "jdbc:postgresql://postgres2_container:5432/postgres?user=postgres&password=postgres",
        "transforms": "unwrap",
        "transforms.unwrap.type": "io.debezium.transforms.UnwrapFromEnvelope",
        "auto.create": "true",
        "insert.mode": "upsert",
        "pk.fields": "id",
        "pk.mode": "record_value"
    }
}

Дебезий / зоокейпер: 0,9

Дебезий / Кафка: 0,9

Дебезий / Postgres: 9,6

debezium / connect: 0.9

JDBC-драйвер PostgreSQL 42.2.5

JDBC Kafka Connect 5.2.1

я попытался понизить драйвер jdbc и подключить kafka, новсе еще есть та же ошибка

1 Ответ

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

решить, потому что, пока я создаю таблицу в postgres1, я не установил id в значение PK

...