KafkaFlume连接器，无主键

vyswwuz2 于 2022-12-26 发布在 Apache

关注(0)|答案(1)|浏览(115)

是否可以写入将基于where子句更新SQL-Server数据库中的记录的接收器连接器？

user
    - ssn int (pk)
    - name varchar
    - email varchar (no index)
    - status

该主题将仅包含

- name
    - email
    - new_status

我希望接收器连接器执行类似于sql

update user
set status = <new_status>
where email = <email>

使用接收器连接器是否可以实现这一点？

1条答案

如果要通过电子邮件字段更新/upsert，可以使用这些属性

"pk.mode": "record_value",
"pk.fields": "email"

https://docs.confluent.io/kafka-connectors/jdbc/current/sink-connector/sink_config_options.html#writes
您可以看到，WHERE查询不能像源连接器那样进行自定义