Kafka Connect JDBC Sink 写入 PostgreSQL 实战

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