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

Reply via email to