Kafka消费者显示的数字格式不可读

要解决Kafka消费者显示的数字格式不可读的问题，可以尝试以下方法：

1. 确认消息的编码格式：首先，确保消息的编码格式与消费者端解码方式匹配。Kafka消息可以使用多种编码格式进行序列化，如JSON、Avro等。如果消息使用了特定的编码格式，消费者在接收消息前需要使用相应的解码方式进行处理。

代码示例：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("group.id", "my-group");

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList("my-topic"));

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));

    for (ConsumerRecord<String, String> record : records) {
        // 使用相应的解码方式处理消息
        String decodedValue = record.value();
        System.out.println(decodedValue);
    }
}

2. 确认消息的序列化方式：如果消息在生产者端进行了自定义的序列化操作，那么在消费者端需要使用相应的反序列化方式进行处理。确保消费者端使用了正确的反序列化方式，以正确还原消息的格式。

代码示例：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.ByteArrayDeserializer");
props.put("group.id", "my-group");

KafkaConsumer<String, byte[]> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList("my-topic"));

while (true) {
    ConsumerRecords<String, byte[]> records = consumer.poll(Duration.ofMillis(100));

    for (ConsumerRecord<String, byte[]> record : records) {
        // 使用相应的反序列化方式处理消息
        String decodedValue = new String(record.value(), StandardCharsets.UTF_8);
        System.out.println(decodedValue);
    }
}

3. 检查数据格式化问题：如果消息的数字格式在消费者端仍然无法解读，可能是由于数据本身的格式化问题。确保消费者端正确解析消息中的数字，并使用适当的格式化方式进行显示。

代码示例：

import java.text.DecimalFormat;

// ...

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));

    for (ConsumerRecord<String, String> record : records) {
        // 解析消息中的数字并进行格式化
        double number = Double.parseDouble(record.value());
        DecimalFormat decimalFormat = new DecimalFormat("#,##0.00");
        String formattedNumber = decimalFormat.format(number);

        System.out.println(formattedNumber);
    }
}

通过以上方法，可以解决Kafka消费者显示的数字格式不可读的问题。根据具体情况选择合适的方法进行处理。