Drainer下放给kafka的binlog日志乱码

[anjia (赵安家)]

换成 ByteArrayDeserializer 而不是String 试试，参考 Java解析drainer发送到kafka中的binlog异常