kafka连接接收器连接器pk.mode,用于具有自动增量的表



我正在为数据库表开发kafka-connect JDBC接收器连接器。

我在将pk.mode配置为支持自动增量的正确pk.mode时遇到问题。最初,我将pk.mode设置为默认的"pk.mode";none";并希望数据库能自动插入一个主键增加一的新记录。然而,我收到了一个错误,抱怨主键不能是";空";。

我尝试了几乎所有其他模式,但现在已经没有什么想法了。我想知道信宿连接器是否曾经支持pk.mode为"pk.mode";自动递增";?

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

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

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

最新更新