Answer the question
In order to leave comments, you need to log in
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 JdbcSinkConnector 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"
}
Caused by: org.apache.kafka.connect.errors.ConnectException: No fields found using key and value schemas for table: topic.
Answer the question
In order to leave comments, you need to log in
Didn't find what you were looking for?
Ask your questionAsk a Question
731 491 924 answers to any question