我正在为一个数据库表开发kafka-connect JDBC接收器连接器。
我无法将pk.mode配置为支持自动递增的正确模式。最初我将pk.mode设置为默认值“none”，并希望数据库将自动插入主键递增1的新记录。但是，我收到错误消息，抱怨主键不能为“null”。
我尝试了几乎所有其他模式，现在运行的想法了。我想知道如果Flume连接器曾经支持pk.模式是“自动增量”？
我正在为一个数据库表开发kafka-connect JDBC接收器连接器。
我无法将pk.mode配置为支持自动递增的正确模式。最初我将pk.mode设置为默认值“none”，并希望数据库将自动插入主键递增1的新记录。但是，我收到错误消息，抱怨主键不能为“null”。
我尝试了几乎所有其他模式，现在运行的想法了。我想知道如果Flume连接器曾经支持pk.模式是“自动增量”？
1条答案
按热度按时间ogq8wdun1#
我刚刚意识到我在为接收器连接器创建的模式中犯了一个错误。
我在模式中包含了主键字段，但该字段未设置，因此当它到达接收器连接器时，它将报告主键不能为空。
为了依赖数据库的自动递增特性，接收器连接器的模式不能包含主键，所以在我从模式中删除主键并将
pk.mode设置为none之后，一切都正常工作。