解决线程池过度关闭问题

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();
 		}
 	}