Hi all,
I'm new to kafak. I'm using kafka to build a ETL program.
Here's my scinaro,
My jdbc connect table t_user have a column sex which is int in mysql, and use
0 to represent male, 1 to represent female.
I want change sex value when 0 then 100, when 1 then 200.
below is my connecter config:
{
"name":"trans-sex",
"config":{
"connector.class":"io.confluent.connect.jdbc.JdbcSourceConnector",
"connection.url":"jdbc:mysql://10.4.89.214:3306/test?user=root&password=root",
"mode":"timestamp",
"table.whitelist":"t_user",
"validate.non.null":false,
"timestamp.column.name":"login_time",
"topic.prefix":"nobinlog.",
"transforms": "convert_sex",
"transforms.convert_sex.type":
"org.apache.kafka.connect.transforms.ReplaceField$Value",
"transforms.convert_sex.renames": "0:100,1,200"
}
}
any ideas,
thanks a lot