JDBC Sink Connector
Target connector
JDBC Sink Connector
JDBC Sink zapisuje rekordy z Kafki do relacyjnych baz, takich jak PostgreSQL, Oracle, MySQL, SQL Server i Db2.
| Kategoria | Parametr | Wymagany | Opis |
|---|---|---|---|
| Basic | name | Tak | Unikalna nazwa konektora docelowego. |
| Basic | connector.class | Tak | Klasa JDBC Sink dostępna w Kafka Connect. |
| Basic | tasks.max | Tak | Liczba tasków sink; zwiększać tylko gdy partycjonowanie i kolejność na to pozwalają. |
| Topics | topics / topics.regex | Tak | Topiki Kafka konsumowane przez target. |
| Connection | connection.url | Tak | JDBC URL do bazy docelowej. |
| Connection | connection.username | Tak | Użytkownik bazy docelowej. |
| Connection | connection.password | Tak | Hasło lub referencja do sekretu. |
| Write mode | insert.mode | Tak | Tryb zapisu, np. insert, upsert albo update, zależnie od connectora. |
| Write mode | delete.enabled | Nie | Obsługa delete/tombstone. |
| Keys | primary.key.mode | Tak | Sposób budowy klucza głównego w target. |
| Keys | primary.key.fields | Warunkowo | Pola klucza głównego, jeśli wymaga tego tryb. |
| Schema | schema.evolution / auto.create / auto.evolve | Nie | Tworzenie lub ewolucja tabel, zależnie od dostawcy connectora. |
| Table mapping | table.name.format | Nie | Mapowanie nazw topiców na tabele docelowe. |
| Runtime | batch.size | Nie | Rozmiar batcha zapisów. |
Przy konsumowaniu topiców Debezium zwykle potrzebna jest transformacja, np. ExtractNewRecordState, aby sink otrzymał payload wiersza zamiast pełnego envelope Debezium.