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.