jhc-systems / debezium-connector-ibmi

Debezium Connector for IBM i (AS/400)
16 stars 12 forks source link

smt to make sinking topics on mass easier #68

Closed msillence closed 9 months ago

msillence commented 9 months ago

for topics named db.company.com.schema.table I want to sink to newschema.table connector config:

    "topics.regex": "db.company.*",
    "transforms": "unwrap,ToLower,ToLowerSink",
    "transforms.unwrap.drop.tombstones": "false",
    "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
    "transforms.ToLowerSink.type": "com.fnz.kakfa.smt.LowerCaseTopicRePrefixSink",
    "transforms.ToLowerSink.prefix": "public",

I was tempted to combine the two, tolower transforms and it is probably worth doing.