这问题我之前帮团队排查过类似的，核心大概率是字符编码不一致在跨环境搞鬼，结合你用的Avro序列化方案，咱们一步步定位：

1. 先检查Avro Schema编译环节的编码 #

Avro默认是UTF-8编码，但如果编译Java类时没强制指定编码，跨环境就会出问题：

• 检查你的Maven/Gradle编译配置，确保插件强制用UTF-8。比如Maven的maven-compiler-plugin要加：

<plugin>
    <groupId>org.apache.maven.plugins</groupId>
    <artifactId>maven-compiler-plugin</artifactId>
    <version>3.8.1</version>
    <configuration>
        <encoding>UTF-8</encoding>
        <source>11</source> <!-- 换成你的JDK版本 -->
        <target>11</target>
    </configuration>
</plugin>

• 确认Avro Schema里的字符串字段没有指定非UTF-8的编码（Avro字符串默认就是UTF-8，除非你手动改了）。

2. 强制Kafka生产者的编码配置 #

虽然KafkaAvroSerializer默认用UTF-8，但StringSerializer可能会 fallback 到系统编码，所以要显式配置：
在你的Spring Boot配置文件里，给生产者加上：

spring.kafka.producer.properties.key.serializer.encoding=UTF-8
# 如果你用的是yml格式：
# spring:
#   kafka:
#     producer:
#       properties:
#         key.serializer.encoding: UTF-8

这会强制StringSerializer用UTF-8序列化key，不受系统环境影响。

3. 检查Unix服务器的JVM与系统编码 #

Unix环境的默认编码可能不是UTF-8，导致JVM启动时继承错误编码：

• 查看服务器的系统编码：执行echo $LANG，确认输出是类似en_US.UTF-8的UTF-8编码；如果不是，需要修改环境变量（比如在/etc/profile里设置export LANG=en_US.UTF-8）。
• 启动JAR时强制指定JVM编码：在启动命令里加上-Dfile.encoding=UTF-8，比如：

java -Dfile.encoding=UTF-8 -jar your-app.jar

这会让JVM全程用UTF-8处理字符，避免系统编码干扰。

4. 验证控制台消费者的编码配置 #

有时候不是消息本身乱码，而是控制台消费者的编码不对：

• 用Confluent的Avro控制台消费者验证：

kafka-avro-console-consumer.sh --bootstrap-server your-kafka:9092 --topic your-topic --from-beginning --property schema.registry.url=http://your-registry:8081

如果这个能正常显示特殊字符，说明消息本身是对的，问题出在普通控制台消费者的编码上。

• 普通控制台消费者要指定编码：

kafka-console-consumer.sh --bootstrap-server your-kafka:9092 --topic your-topic --from-beginning --property print.key.encoding=UTF-8 --property print.value.encoding=UTF-8

同时确保你查看控制台的终端（比如SSH客户端）的编码也是UTF-8。

快速验证步骤 #

1. 先用Avro控制台消费者看消息是否正常，排除生产者问题；
2. 检查编译配置和JVM启动参数，确保编码统一为UTF-8；
3. 最后确认系统和终端的编码设置。

内容的提问来源于stack exchange，提问作者MrP