cdc connectors¶
Change Data Capture integrations. All six connectors wrap Debezium connectors (running as separate Kafka Connect / standalone processes) and consume their JSON events via HTTP polling or Kafka tail. They share helper code in helpers.go. None use a native binary SDK — the actual binary log work happens inside the Debezium runtime.
Connectors in this category¶
| Connector | URI / type | Auth | Native SDK | One-line description |
|---|---|---|---|---|
debezium_db2 |
connector://debz-db2/send |
Basic / token | No (HTTP) | Debezium CDC adapter for IBM Db2 logical reads. |
debezium_mongodb |
connector://debz-mongo/send |
Basic / token | No (HTTP) | Debezium CDC adapter for MongoDB change-stream tail. |
debezium_mysql |
connector://debz-mysql/send |
Basic / token | No (HTTP) | Debezium CDC adapter for MySQL binlog. |
debezium_oracle |
connector://debz-oracle/send |
Basic / token | No (HTTP) | Debezium CDC adapter for Oracle LogMiner / XStream. |
debezium_postgres |
connector://debz-pg/send |
Basic / token | No (HTTP) | Debezium CDC adapter for PostgreSQL logical-decoding (pgoutput / wal2json). |
debezium_sqlserver |
connector://debz-mssql/send |
Basic / token | No (HTTP) | Debezium CDC adapter for SQL Server CDC tables. |
helpers.go is internal — shared event-parsing utilities for the six Debezium connectors. Not a registered connector.
See also¶
- Connector SDK guide — adding a new connector
pgeventconnector under database — nativepgx/v5LISTEN/NOTIFY for an SDK-level alternative to Debezium PostgreSQLkafka://component — typical sink for Debezium CDC events