标题怎么说,有没有一种方法可以设置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=
有没有一个属性可以满足我的要求?
1条答案
按热度按时间9wbgstp71#
您可以通过使用kafka connect smt来实现这一点,尝试添加以下配置: