Debezium connector topic reroute key/value field type mismatch on decmal.handling.mode used

Viewed 13

I've a table like below structure
customer(CustID:Decimal(9,4) PK, FName varchar(50), LName varchar(50))
When I try to send data using debezium with below config, for the Key field CustID, it's decimal type in Key schema, while it's String in Value schema(as intended in the decimal.handling.mode). Why I'm getting a type mismatch, does the decimal.handling.mode losses the setting 'String' after reroute into a new topic for Key schema?

"decimal.handling.mode":"string",
"transforms": "Reroute",
"transforms.Reroute.type": "io.debezium.transforms.ByLogicalTableRouter",
"transforms.Reroute.topic.regex": "server-stage.stg.customer",
"transforms.Reroute.topic.replacement": "caldo.customer",
"transforms.Reroute.key.enforce.uniqueness":"false"
0 Answers
Related