@@ -188,7 +188,6 @@ public class MysqlConsumerListener implements RecordListener {
if(fieldDataMap.get("Id") != null){
res.put("id", fieldDataMap.get("Id").getValue());
}
- res.put("id", fieldDataMap.get("Id").getValue());
return res;