8eb64381e3
Add atc-lake01 compose with s3-kafka-consumer; redact DB passwords in connector JSON.
Debezium connector definitions
Register on atc-lake01 via POST http://10.0.21.50:8083/connectors with JSON body { "name": "...", "config": { ... } }.
Passwords use ${DEBEZIUM_DB_PASSWORD} — set on the host, not in git.
| Connector | Source DB | Topic prefix |
|---|---|---|
| postgres-sales-connector | postgres @ 10.0.21.51 public.sales_orders |
postgres_sales |
| mysql-hr-connector | mysql hr.employee_events | mysql_hr |
| mongodb-supplychain-connector | mongodb supplychain.events | mongodb_supplychain |
Cassandra CDC skipped (requires table CDC + agent).