Данные не переносятся из Кафки в Постгрес?

Question

[albertalexandrov]

Привет всем!)

Стоит задача перемещать данные из Кафки в Постгрес. Для этого я создал коннектор Jdbc​Sink​Connector со следующими настройками:

{
  "key.converter.schemas.enable": "false",
  "value.converter.schemas.enable": "false",
  "name": "MVM",
  "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
  "key.converter": "org.apache.kafka.connect.json.JsonConverter",
  "value.converter": "org.apache.kafka.connect.json.JsonConverter",
  "errors.log.enable": "true",
  "errors.log.include.messages": "true",
  "topics": [
    "topic"
  ],
  "connection.url": "connection",
  "connection.user": "user",
  "connection.password": "*************",
  "auto.create": "false",
  "auto.evolve": "false"
}

При попытке заиспользовать валится ошибка:

Caused by: org.apache.kafka.connect.errors.ConnectException: No fields found using key and value schemas for table: topic.

Прошу подсказать, как это исправить?

П.С. Смущает то, что в тесте ошибки topic - это table.