ERROR WorkerSinkTask{id=12sink-0} Task threw an uncaught and unrecoverable exception.patient3" to add missing field SinkRecordField{schema=Schema{io.debezium.connector.postgresql.Source::75)
at io.confluent.connect.jdbc.sink.BufferedReco
Kafka消息未插入到postgresql数据库中。我可以看到消费者中的消息,但它没有插入到表中。任何建议都会有帮助。Sink_connect.properties connection.url=jdbc:postgresql://localhost:5432/postgrespassword03:50:09,940] INFO Kafka Connect started (org.apache.kafka.c
found for jdbc:postgresql://localhost:5432/casb at io.confluent.connect.jdbc.sink.JdbcSinkTask.put(JdbcSinkTask.java:69)
at org.apache.kafka.connect.runtime.WorkerSinkTa
我使用JDBCSink连接器将数据从Kafka主题加载到Postgres表中。首先,我用"AVRO“值格式创建了一个主题和它上面的一个流。=1, VALUE_FORMAT='AVRO');curl -X PUT http://localhost:8083/connectors/sink-jdbc-postgre(CachedConnectionPro