MySQL Source Connector
Source connector
MySQL Source Connector
MySQL replication uses the Debezium MySQL connector and reads changes from the binary log. Database filters use database-level parameters instead of PostgreSQL-style schemas.
Connector Class
io.debezium.connector.mysql.MySqlConnector
Parameters
| Category | Parameter | Required | Recommended / Default | Description |
|---|---|---|---|---|
| Basic | name | Yes | User-defined | Unique connector name. GIFROST derives topic.prefix as <name>-server. |
| Basic | tasks.max | Yes | 1 | Keep one task for ordered binlog reading. |
| Database Connection | database.hostname | Yes | From Database Store | MySQL host. |
| Database Connection | database.port | Yes | 3306 | MySQL port. |
| Database Connection | database.user | Yes | From Database Store | Replication user. |
| Database Connection | database.password | Yes | Hidden | Password or secret reference. |
| Database Settings | database.server.id | Yes | Unique integer | Unique MySQL replication server id. |
| Database Wizard | database.include.list / database.exclude.list | No | Generated | Database filters generated by the wizard. |
| Database Wizard | table.include.list / table.exclude.list | No | Generated | Table filters. |
| Database Wizard | column.include.list / column.exclude.list | No | Generated | Column filters. |
| Database Wizard | message.key.columns | Conditional | Generated | Custom keys for tables without primary keys. |
| Snapshot | snapshot.mode | No | initial | Initial loading behavior. |
| Snapshot | snapshot.locking.mode | No | Deployment-specific | Controls locking during snapshot. |
| Signal | signal.data.collection | Conditional | <databaseName>.<tableName> | Signal table. |
| Events | include.schema.changes | No | Deployment-specific | Emits schema change records when enabled. |