Kafka Connect JDBC Sink 写入 PostgreSQL 实战

---

title: Kafka Connect JDBC Sink 写入 PostgreSQL 实战

keywords: JdbcSinkConnector, auto.create, insert.mode, pk.mode, table.name.format

description: 配置 JDBC Sink 将 Kafka 主题写入 PostgreSQL，启用自动建表、主键与插入模式，实现稳定的数据落库。

tags:

• JDBC
• JdbcSinkConnector
• Kafka
• auto.create
• insert.mode
• pk.mode
• table.name.format
• 数据流

categories:

• 文章资讯
• 技术教程

---

jdbc-sink.json：

{
  "name": "jdbc-sink-postgres",
  "config": {
    "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
    "tasks.max": "2",
    "topics": "orders",
    "connection.url": "jdbc:postgresql://pg:5432/app",
    "connection.user": "writer",
    "connection.password": "secret",
    "auto.create": "true",
    "auto.evolve": "true",
    "insert.mode": "upsert",
    "pk.mode": "record_key",
    "pk.fields": "id",
    "table.name.format": "public.${topic}",
    "delete.enabled": "false"
  }
}

REST 创建与状态：

curl -X POST -H "Content-Type: application/json" --data @jdbc-sink.json http://localhost:8083/connectors
curl http://localhost:8083/connectors/jdbc-sink-postgres/status