消费订阅数据 消费数据乱码问题 对于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", "UTF-