铭牌增加日志

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java

@@ -53,7 +53,8 @@ public class NameplateKafkaConsumer {
     public void listen(String recordMessages, Acknowledgment ack,
                        @Header(KafkaHeaders.RECEIVED_PARTITION_ID) Integer partitionId,
                        @Header(KafkaHeaders.OFFSET) Long offset) {
-
+        log.info("nameplateKafkaConsumer 当前线程: {}, 线程ID: {},计数：{}", Thread.currentThread().getName(), Thread.currentThread().getId());
+        log.info("nameplateKafkaConsumerMessage，消息：{}", recordMessages);
         if (StringUtils.isEmpty(recordMessages)) {
             ack.acknowledge();
             return;