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