11
PostgreSQL
Параллельное JDBC-чтение, Debezium CDC, staging + upsert.
db
streaming
postgresql
Контрольные задания
✓
Прочитать таблицу параллельно через partitionColumn
✓
Ограничить число JDBC connections
✓
Собрать Debezium → Iceberg pipeline
Уроки модуля
1
JDBC Connector: базовое чтение, параметры подключения и JDBC URL
2
Parallel JDBC Read: partitionColumn, lowerBound, upperBound, numPartitions
3
Predicates: Custom Query и фильтрация на стороне PostgreSQL
4
Connection Pool: ограничение числа соединений и fetchsize
5
Write Modes: append, overwrite и staging-таблица для upsert
6
PostgreSQL WAL: как работает Write-Ahead Log и logical replication
7
Debezium CDC: replication slots, snapshot mode и структура Kafka-сообщений
8
CDC Events: envelope формат, before/after поля и обработка операций