Przejdź do głównej zawartości

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
KategoriaParametrWymaganyZalecane / domyślneOpis
BasicnameTakWartość użytkownikaUnikalna nazwa connectora. GIFROST tworzy topic.prefix jako <name>-server.
Basictasks.maxTak1Jedno zadanie dla uporządkowanego odczytu WAL.
Database Connectiondatabase.hostnameTakDatabase StoreHost PostgreSQL.
Database Connectiondatabase.portTak5432Port PostgreSQL.
Database Connectiondatabase.userTakDatabase StoreUżytkownik replikacyjny.
Database Connectiondatabase.passwordTakUkryteHasło lub referencja do sekretu.
Database Connectiondatabase.dbnameTakDatabase StoreNazwa bazy.
Database Settingsplugin.nameTakpgoutputPlugin logical decoding.
Database Settingsslot.nameTakdebezium_<connector-name>Slot replikacyjny śledzący pozycję WAL.
Database Settingspublication.nameTakdbz_publicationPublikacja PostgreSQL dla pgoutput.
Database Settingspublication.autocreate.modeNieall_tablesAutomatyczne tworzenie publikacji.
Database Settingsslot.drop.on.stopNieEnabledUsuwa slot przy kontrolowanym zatrzymaniu.
Database Wizardschema.include.list / schema.exclude.listNieGenerowaneFiltry schematów.
Database Wizardtable.include.list / table.exclude.listNieGenerowaneFiltry tabel.
Database Wizardcolumn.include.list / column.exclude.listNieGenerowaneFiltry kolumn.
Database Wizardmessage.key.columnsWarunkowoGenerowaneKlucze dla tabel bez primary key.
Snapshotsnapshot.modeNieinitialTryb pierwszego ładowania.
Signalsignal.data.collectionWarunkowo<schemaName>.<tableName>Tabela sygnałów Debezium.
Notificationnotification.sink.topic.nameNie<connector-name>-notificationsTopic notyfikacji.

Źródło

Debezium PostgreSQL connector