From 5ffd0e5f8f2f72a1db83addca440e1d0e9f60102 Mon Sep 17 00:00:00 2001 From: ZLI263 Date: Wed, 24 Sep 2025 10:33:24 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E7=BA=BF=E7=A8=8B=E6=B1=A0?= =?UTF-8?q?=E8=BF=87=E5=BA=A6=E5=85=B3=E9=97=AD=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ai/analytic/center/mq/CorpusProcessKafkaProducer.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java index 6cd261a..5962235 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java @@ -115,21 +115,17 @@ public class CorpusProcessKafkaProducer { } } catch (Exception e) { log.error("CorpusProcessKafkaProducer 电话语料 解析JSON出错: {}", e.getMessage()); - }finally { - executor.shutdown(); } }); } - executor.shutdown(); + } log.info("Kafka 消息处理完成，耗时：{}", System.currentTimeMillis() - startTime); // 在这里可以添加对解析后的对象的进一步处理逻辑 } catch (Exception e) { log.error("CorpusProcessKafkaProducer 电话语料 解析JSON出错: {}" , e.getMessage()); - }finally { - executor.shutdown(); } }