消费订阅数据 消费数据乱码问题 对于Java生产者和消费者,可以在配置中设置字符编码: props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("serializer.encoding", "UTF8"); // 设置编码格式 props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); props.put("deserializer.encoding", "UTF8"); // 设置编码格式 如果使用的是命令行工具,确保控制台的字符编码与Kafka消息编码一致。 在Windows系统中,可以通过修改控制台默认编码为UTF8来解决: chcp 65001 在Linux系统中,可以通过设置环境变量来调整字符编码: export LANGenUS.UTF8
来自: