如何让数据库自动填充自增主键而非在Kafka Producer中显式设置

问题核心：你当前的Sink Connector配置pk.mode="record_value"要求从消息体的id字段提取主键值，但Producer未传入id，Schema默认填充了0，而数据库期望自动生成主键，两者冲突导致写入失败。

解决建议：

• 不要删除Schema中的id字段：保留该字段可后续接收数据库生成的主键值（若需要将主键回写到Kafka），避免后续扩展受限。
• 修改Sink Connector的pk.mode配置：
  • 改成pk.mode="none"：这会让Sink Connector完全依赖数据库的自动主键生成逻辑，不再从消息体读取id作为主键，数据库会自行生成合法主键值，解决0值冲突问题。
  • 若业务允许，也可设为pk.mode="kafka"：用Kafka消息的topic+partition+offset作为主键，但这种方案更适合不需要数据库自增主键的场景，你的需求下none是更匹配的选择。

配置修改后，重启Sink Connector，再发送测试消息验证数据库是否能正常新增记录。

内容的提问来源于stack exchange，提问作者Ckey