kafka log 打印

amos-boot-utils/amos-boot-utils-message/src/main/java/com/yeejoin/amos/message/kafka/KafkaConsumerService.java

@@ -74,9 +74,9 @@ public class KafkaConsumerService implements ApplicationRunner {
      */
     @KafkaListener(id = "kafkaRoma", groupId = "kafkaRoma", topics = "#{'${queue.kafka.topics}'.split(',')}", containerFactory = "kafkaRomaContainerFactory")
     public void kafkaListener(ConsumerRecord<?, String> record, Acknowledgment ack) {
-        log.info("kafka上报数据：{}", JSON.toJSONString(record));
         try {
             Optional<?> messages = Optional.ofNullable(record.value());
+            log.info("kafka上报数据：{}", record.toString());
             if (messages.isPresent()) {
                 JSONObject object = JSONObject.fromObject(record.value());
                 com.alibaba.fastjson.JSONObject jsonObj = ClassToJsonUtil.class2json(object, commonMessage, record.topic());