From 1f6ce44c51fa8eaae835fce425ad01c9eb3498e0 Mon Sep 17 00:00:00 2001 From: ZLI263 Date: Fri, 19 Sep 2025 12:57:21 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../analytic/center/mq/NameplateKafkaConsumer.java | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java index b0467c6..83cb4cd 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java +++ b/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); }