binlog同步到kafka，truncate操作动态分区错误

环境信息

canal v1.1.5-alpha-2 mysql 5.7

问题描述

场景：binlog同步到kafka，topic配置多partition，根据表名动态分区 问题：kafka中truncate事件的操作类型为dml（这个是否应该归类于ddl？），但是在配置了动态分区的情况下，并没有进行动态分区，而是作为dml操作默认进入partition 0

LogEventConvert.java boolean isDml = (type == EventType.INSERT || type == EventType.UPDATE || type == EventType.DELETE);

MQMessageUtils.java if (rowChange.getIsDdl()) { partitionEntries[0].add(entry); }

期待结果

truncate操作也可以根据表名进行动态分区

现执行情况

truncate操作默认发送到0号分区

原提问者GitHub用户xiehaochn