search

confluentinc / kafka-connect-jdbc

Kafka Connect connector for JDBC-compatible databases
Other
19 stars 955 forks source link

cannot execute truncate operation for postgresql via sink connector #1282

Open wangshuang0220 opened 1 year ago

wangshuang0220 commented 1 year ago

source connector : debezium,and enable truncate operation { "op": "t", "ts_ms": 1670898970410, "transaction": null } cannot execute truncate operation for postgresql via sink connector

rlebreto commented 10 months ago

same issue for me. truncate fails with this message : ... is configured with 'delete.enabled=true' and 'pk.mode=record_key' and therefore requires records with a non-null key and non-null Struct or primitive key schema, but found record at ...

But there is not PK for a truncate message.