From 3588f7a2504203b386c52e3d1e704ef5a0db0818 Mon Sep 17 00:00:00 2001 From: ismail simsek <6005685+ismailsimsek@users.noreply.github.com> Date: Sat, 1 Apr 2023 17:41:24 +0200 Subject: [PATCH] Document IcebergOffsetBackingStore, IcebergSchemaHistory storage classes (#183) --- docs/DOCS.md | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) diff --git a/docs/DOCS.md b/docs/DOCS.md index ea6f210e..d02c0d70 100644 --- a/docs/DOCS.md +++ b/docs/DOCS.md @@ -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