使用kafka客户端消费binlog出现乱码

kafka发送的是message数据包不是可见字符串，客户端接收到后需要反序列化解包，参考client.kafka

原回答者GitHub用户rewerma

在使用kafka客户端消费binlog的过程中出现乱码，可能是因为字符集的问题导致的。可以尝试在创建Kafka Producer和Consumer时设置字符集为UTF-8，即在Producer和Consumer的配置文件中添加以下内容：

props.put("key.serializer.encoding", "UTF8");
props.put("value.serializer.encoding", "UTF8");

props.put("key.deserializer.encoding", "UTF8");
props.put("value.deserializer.encoding", "UTF8");

另外，还可以在MySQL中设置字符集为UTF-8，即在my.cnf文件中添加以下内容：

[client]
default-character-set=utf8

[mysql]
default-character-set=utf8

[mysqld]
character-set-server=utf8
collation-server=utf8_general_ci

如果以上方法都不能解决问题，可以尝试使用其他解析binlog的工具，如Debezium等。