ReplaceField SMT does not work after flatten SMT

Kafka Connect
1

why RenameField SMT does not work after flatten SMT.

“transforms”: “flatten,renameField”,
“transforms.flatten.type”: “org.apache.kafka.connect.transforms.Flatten$Value”,
“transforms.flatten.delimiter”: “_”,
“transforms.renameField.type”: “org.apache.kafka.connect.transforms.ReplaceField$Value”,
“transforms.renameField.renames”: “ACTORUSER_DEPARTMENT:department,ACTORUSER_EMAIL:email”,

Input

{“actorUser”:
{“aaa.order.ActorUser”:
{
“department”:“IT”,
“email":"xxx.yyy@fff.com”
}
}
}

after flatten and JDBC SINK connector created table with below columns
actoruser_department
actoruser_email

I wanted to rename actoruser_department with department and actoruser_email with email so that the table getting created with department and email column names.

2

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.