Konektor źródłowy PostgreSQL
Source connector
Konektor źródłowy PostgreSQL
Replikacja PostgreSQL korzysta z Debezium PostgreSQL connector i logical decoding. Wspólne kroki kreatora opisuje strona Przepływ źródła.
Klasa konektora
io.debezium.connector.postgresql.PostgresConnector
| Kategoria | Parametr | Wymagany | Zalecane / domyślne | Opis |
|---|---|---|---|---|
| Basic | name | Tak | Wartość użytkownika | Unikalna nazwa connectora. GIFROST tworzy topic.prefix jako <name>-server. |
| Basic | tasks.max | Tak | 1 | Jedno zadanie dla uporządkowanego odczytu WAL. |
| Database Connection | database.hostname | Tak | Database Store | Host PostgreSQL. |
| Database Connection | database.port | Tak | 5432 | Port PostgreSQL. |
| Database Connection | database.user | Tak | Database Store | Użytkownik replikacyjny. |
| Database Connection | database.password | Tak | Ukryte | Hasło lub referencja do sekretu. |
| Database Connection | database.dbname | Tak | Database Store | Nazwa bazy. |
| Database Settings | plugin.name | Tak | pgoutput | Plugin logical decoding. |
| Database Settings | slot.name | Tak | debezium_<connector-name> | Slot replikacyjny śledzący pozycję WAL. |
| Database Settings | publication.name | Tak | dbz_publication | Publikacja PostgreSQL dla pgoutput. |
| Database Settings | publication.autocreate.mode | Nie | all_tables | Automatyczne tworzenie publikacji. |
| Database Settings | slot.drop.on.stop | Nie | Enabled | Usuwa slot przy kontrolowanym zatrzymaniu. |
| Database Wizard | schema.include.list / schema.exclude.list | Nie | Generowane | Filtry schematów. |
| Database Wizard | table.include.list / table.exclude.list | Nie | Generowane | Filtry tabel. |
| Database Wizard | column.include.list / column.exclude.list | Nie | Generowane | Filtry kolumn. |
| Database Wizard | message.key.columns | Warunkowo | Generowane | Klucze dla tabel bez primary key. |
| Snapshot | snapshot.mode | Nie | initial | Tryb pierwszego ładowania. |
| Signal | signal.data.collection | Warunkowo | <schemaName>.<tableName> | Tabela sygnałów Debezium. |
| Notification | notification.sink.topic.name | Nie | <connector-name>-notifications | Topic notyfikacji. |