A
A
albertalexandrov2020-01-16 18:12:46
Apache HTTP Server
albertalexandrov, 2020-01-16 18:12:46

Data not being transferred from Kafka to Postgres?

Hello everyone!)
The task is to move data from Kafka to Postgres. To do this, I created a Jdbc​Sink​Connector with the following settings:

{
  "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"
}

When I try to use it, I get an error:
Caused by: org.apache.kafka.connect.errors.ConnectException: No fields found using key and value schemas for table: topic.

Please advise how to fix this?
P.S. Confusingly, in the error test, topic is table.

Answer the question

In order to leave comments, you need to log in

Didn't find what you were looking for?

Ask your question

Ask a Question

731 491 924 answers to any question