对不起，我的英语不好。我是新来Kafka的。问题是我通过kafka从postgres数据库中提取数据，然后将数据放入另一个postgres数据库中，为此我使用kafka connect（debezium）。我有一个带有复合键的表，比如（ref\u id pk，lang\u id pk）。问题是当我把这张table扔给邮局的时候。表的创建、插入和更新都很好地工作，但删除行连接器时会中断。如何解决至少jdbcsinkconnector没有断开如果记录可以删除那就好了？debezium接收器连接器配置为：

{       "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
        "taks.max": "2",
        "topics.regex": "^xxxx_(.*).(.*)_ml$",
        "connection.user": "xxxx",
        "table.name.format": "${topic}",
        "connection.password": "xxxx",
        "connection.url": "jdbc:postgresql://xx.xx.xxx.xx:5432/xxxx?currentSchema=data&user=xxxx&password=xxxx",
        "auto.create": "true",
        "auto.evolve": "true",
        "transforms": "dropPrefix, unwrap",
        "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
        "transforms.unwrap.drop.tombstones": "false",
        "insert.mode": "upsert",
        "pk.mode": "record_value",
        "pk.fields": "id,lang_id",
        "delete.enabled": "false" 
}

这个 PreparedStatementBinder.class 在第125行中断nullpointerexception；