Fix reading config values in debezium storage classes

memiiso / debezium-server-iceberg

Replicates any database (CDC events) to Apache Iceberg (To Cloud Storage)

Apache License 2.0

171 stars 35 forks source link

Fix reading config values in debezium storage classes #327

Closed ismailsimsek closed 1 month ago

ismailsimsek commented 1 month ago

Debezium uses consumer name to filter config and sends subset of config to storage classes (OffsetBackingStore, SchemaHistory) this causes issues with iceicebergeventsberg consumer.

with the fix this issues is resolved. Now storage classes are reading config correctly.

Resolves https://github.com/memiiso/debezium-server-iceberg/issues/326