添加日志

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

@@ -80,8 +80,13 @@ public class NameplateKafkaConsumer {
 							log.error("corpusPortrait画像铭牌异步任务执行失败", e);
 						} finally {
 							log.info("corpusPortrait 释放锁，availablePermits  {}", semaphore.availablePermits());
-
+							try {
+								ack.acknowledge(); // 提交 offset
+							} catch (IllegalStateException e) {
+								log.warn("Offset 已提交，跳过重复提交");
+							}
 							semaphore.release(); // 释放许可
+							log.error("释放许可，当前可用许可数:{}",semaphore.availablePermits());
 						}
 					}, executor));
 
@@ -89,12 +94,6 @@ public class NameplateKafkaConsumer {
 			 // 手动提交 offset
 		} catch (Exception e) {
 			log.info("nameplateKafkaConsumerFailed to process message: {}",  e);
-		}finally {
-			try {
-				ack.acknowledge(); // 提交 offset
-			} catch (IllegalStateException e) {
-				log.warn("Offset 已提交，跳过重复提交");
-			}
 		}
 		log.info("nameplateKafkaConsumer消息处理开始，耗时：{}", System.currentTimeMillis() - startTime);
 	}