kafka-connect sink connector pk.mode for table with auto-increment

Question

我正在研究 kafka-connect JDBC 数据库的接收器连接器 table。

我在将 pk.mode 配置为支持自动递增的正确设置时遇到问题。最初我将 pk.mode 设置为默认的“none”，并希望数据库自动插入一条主键递增 1 的新记录。但是我收到错误消息，抱怨主键不能为“null”。

我尝试了几乎所有其他模式，现在 运行 没主意了。我想知道接收器连接器是否支持 pk.mode 是“自动递增”？

Answer 1

我刚刚意识到我在为接收器连接器创建的架构中犯了一个错误。

我在架构中包含了主键字段，但此字段未设置，因此当它到达接收器连接器时，它会抱怨主键不能为空。

为了依赖数据库的自动递增功能，接收器连接器的架构不得包含主键。因此，在我从架构中删除主键并将 pk.mode 设置为 none 后，一切正常。