Files
mo 8eb64381e3 Document lakehouse Debezium connectors and updated docker inventory.
Add atc-lake01 compose with s3-kafka-consumer; redact DB passwords in connector JSON.
2026-06-04 02:27:23 +02:00

14 lines
609 B
Markdown

# 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).