binlog写入Kafka,获取到的message有乱码的问题

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

—这个试试?