问题描述，分析： *前提：*安装配置完成 /usr/local/canal-adapter/conf/application.yml /usr/local/canal-adapter/conf/es6 等配置完成
1. 创建索引：
"createTime": { "type": "date", "format": "yyyy-MM-dd HH:mm:ss || yyyy-MM-dd || yyyy/MM/dd HH:mm:ss|| yyyy/MM/dd ||epoch_millis" },根据日志：
DEBUG c.a.o.canal.client.adapter.es.core.service.ESSyncService - DML:中data的信息找到： "create_time":1599031621000确认数据库查询是java.sql.Timestamp 可以知道canal同步数据时候时间转换存在问题。
2. 下载canal源码：
https://github.com/alibaba/canal/releases https://github.com/alibaba/canal/releases/tag/canal-1.1.5-alpha-1 备忘下载：https://toolwa.com/github/ 结构： 找到ES6xTemplate类找到读取mapping的地方getValFromData方法：
// 如果是对象类型 if (mapping.getObjFields().containsKey(fieldName)) { return ESSyncUtil.convertToEsObj(value, mapping.getObjFields().get(fieldName)); } else { return ESSyncUtil.typeConvert(value, esType); }最终定位到：typeConvert方法，继续跟踪到ESSyncUtil中 找到type为date的地方： 解释：本来我的日期就是正常的北京时间所以我所需要的就是直接改掉+8:00以及T并不需要 2020-06-23T06:52:56.000+08:00----》2020-06-23 06:52:56 注意，根据每个人的不同进行更改，复杂的存储需要自己进行存储时候更改，目前本人只存在根据binglog同步各个单表，根据业务需求自己定。
3. 修改源码
修改源码：（logger.info请忽略）
else if ("date".equals(esType)) { if (val instanceof java.sql.Time) { DateTime dateTime = new DateTime(((java.sql.Time) val).getTime()); if (dateTime.getMillisOfSecond() != 0) { res = dateTime.toString("HH:mm:ss.SSS"); } else { res = dateTime.toString("HH:mm:ss"); } } else if (val instanceof java.sql.Timestamp) { DateTime dateTime = new DateTime(((java.sql.Timestamp) val).getTime()); if (dateTime.getMillisOfSecond() != 0) { logger.info("Timestamp1"+dateTime.toString()); res = dateTime.toString("yyyy-MM-dd HH:mm:ss.SSS"); logger.info("Timestamp2"+res.toString()); } else { logger.info("Timestamp3"+dateTime.toString()); res = dateTime.toString("yyyy-MM-dd HH:mm:ss"); logger.info("Timestamp4"+res); } } else if (val instanceof java.sql.Date || val instanceof Date) { logger.info("Date1"+val.toString()); DateTime dateTime; if (val instanceof java.sql.Date) { dateTime = new DateTime(((java.sql.Date) val).getTime()); } else { dateTime = new DateTime(((Date) val).getTime()); } if (dateTime.getHourOfDay() == 0 && dateTime.getMinuteOfHour() == 0 && dateTime.getSecondOfMinute() == 0 && dateTime.getMillisOfSecond() == 0) { res = dateTime.toString("yyyy-MM-dd"); } else { logger.info("Date2"+dateTime.toString()); if (dateTime.getMillisOfSecond() != 0) { res = dateTime.toString("yyyy-MM-dd HH:mm:ss.SSS"); } else { res = dateTime.toString("yyyy-MM-dd HH:mm:ss"); } } } else if (val instanceof Long) { if(((Long)val) < 10000000000L){ res = val; }else { logger.info("Long1"+val.toString()); DateTime dateTime = new DateTime(((Long) val).longValue()); if (dateTime.getHourOfDay() == 0 && dateTime.getMinuteOfHour() == 0 && dateTime.getSecondOfMinute() == 0 && dateTime.getMillisOfSecond() == 0) { res = dateTime.toString("yyyy-MM-dd"); } else if (dateTime.getMillisOfSecond() != 0) { res = dateTime.toString("yyyy-MM-dd HH:mm:ss.SSS"); /*res = dateTime.toString("yyyy-MM-dd'T'HH:mm:ss.SSS" + Util.timeZone);*/ } else { res = dateTime.toString("yyyy-MM-dd HH:mm:ss"); } }**
4. 打包替换：
maven打包后找到自己的目录如： F:\es\canal-canal-1.1.5-alpha-2 (1)\canal-canal-1.1.5-alpha-2\client-adapter\launcher\target\canal-adapter\plugin 导入到 /usr/local/canal-adapter/plugin目录下替换。（注意红框的包，如果不确定哪一个，直接全拉进去替换就是了）
drwxr-xr-x. 2 root root 95 9月 3 14:16 bin drwxrwxrwx. 7 root root 131 9月 3 14:16 conf drwxr-xr-x. 2 root root 8192 9月 3 10:16 lib drwxrwxrwx. 3 root root 21 9月 3 11:14 logs drwxrwxrwx. 2 root root 4096 9月 3 11:40 plugin [root@localhost canal-adapter]# pwd /usr/local/canal-adapter [root@localhost canal-adapter]#与 注意:如果创建索引时候只是"format": “yyyy-MM-dd HH:mm:ss”：
"createTime": { "type": "date", "format": "yyyy-MM-dd HH:mm:ss" },会报错（原因自行百度）：
ElasticsearchException[Elasticsearch exception [type=illegal_argument_exception, reason=Invalid format: "2020-09-02 15:27:01" is malformed at "-09-02 15:27:01"]];