Skip to content

Commit

Permalink
Document IcebergOffsetBackingStore, IcebergSchemaHistory storage clas…
Browse files Browse the repository at this point in the history
…ses (#183)
  • Loading branch information
ismailsimsek committed Apr 1, 2023
1 parent 5d6711e commit 3588f7a
Showing 1 changed file with 19 additions and 0 deletions.
19 changes: 19 additions & 0 deletions docs/DOCS.md
Original file line number Diff line number Diff line change
Expand Up @@ -110,9 +110,28 @@ debezium.sink.iceberg.table-prefix=cdc_
With above config database table = `inventory.customers` is replicated to `default.testc_cdc_inventory_customers`
## IcebergOffsetBackingStore Offset Storage
This implementation saves CDC offset to an iceberg table.
```
debezium.source.offset.storage=io.debezium.server.iceberg.offset.IcebergOffsetBackingStore
debezium.source.offset.storage.iceberg.table-name=debezium_offset_storage_table
```
## IcebergSchemaHistory Database History Storage
This implementation saves database history to an iceberg table.
```properties
debezium.source.database.history=io.debezium.server.iceberg.history.IcebergSchemaHistory
debezium.source.database.history.iceberg.table-name=debezium_database_history_storage_table
```
## Debezium Event Flattening
Iceberg consumer requires event flattening.
```properties
debezium.transforms=unwrap
debezium.transforms.unwrap.type=io.debezium.transforms.ExtractNewRecordState
Expand Down

0 comments on commit 3588f7a

Please sign in to comment.