Debezium PostgreSQL Source 连接器变更捕获到 Kafka 实战

连接器配置（debezium-postgres.json）： ``` { "name": "debezium-postgres-src", "config": { "connector.class": "io.debezium.connector.postgresql.PostgresConnector", "tasks.max": "1", "database.hostname": "pg", "database.port": "5432", "database.user": "replicator", "database.password": "secret", "database.dbname": "app", "slot.name": "app_slot", "publication.autocreate.mode": "filtered", "plugin.name": "pgoutput", "topic.prefix": "app", "table.include.list": "public.users,public.orders", "include.schema.changes": "true", "decimal.handling.mode": "precise" } } ``` 通过 REST 创建并查看状态： ``` curl -X POST -H "Content-Type: application/json" --data @debezium-postgres.json http://localhost:8083/connectors curl http://localhost:8083/connectors/debezium-postgres-src/status ```