jdbc连接器将主键设置到消息中

f0ofjuux 于 2021-06-04 发布在 Kafka

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

标题怎么说，有没有一种方法可以设置kafka jdbc源连接器从数据库读取的记录的主键？
这是来自的配置 connect-file-source.properties ```
name=jdbc_source_postgres_foobar_01
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
connection.url=jdbc:postgresql://localhost:5432/db?user=postgres&password=root
table.whitelist=author
mode=timestamp+incrementing
incrementing.column.name=id
timestamp.column.name=entity_modify_date
validate.non.null=false
topics=migration
topic.prefix=

有没有一个属性可以满足我的要求？

apache-kafka apache-kafka-connect

来源：https://stackoverflow.com/questions/64385055/how-to-set-primary-key-into-message-by-kafka-jdbc-connector

1条答案

按热度按时间

9wbgstp71#

您可以通过使用kafka connect smt来实现这一点，尝试添加以下配置：

transforms=createKey,extractInt
transforms.createKey.type=org.apache.kafka.connect.transforms.ValueToKey
transforms.createKey.fields=id
transforms.extractInt.type=org.apache.kafka.connect.transforms.ExtractField$Key
transforms.extractInt.field=specialization_id

赞(0）回复(0）举报 2021-06-04

我来回答

jdbc连接器将主键设置到消息中

1条答案

相关问题

热门标签

最新问答