From 4f3c1ad9b6d921c19f4d8732193e1bf1284eee1a Mon Sep 17 00:00:00 2001 From: zengqiao Date: Wed, 19 Jan 2022 20:23:18 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96corn=E8=A1=A8=E8=BE=BE?= =?UTF-8?q?=E5=BC=8F=E8=A7=A3=E6=9E=90=E5=A4=B1=E8=B4=A5=E5=90=8E=E9=80=80?= =?UTF-8?q?=E5=87=BA=E6=97=A0=E4=BB=BB=E4=BD=95=E6=97=A5=E5=BF=97=E6=8F=90?= =?UTF-8?q?=E7=A4=BA=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../kafka/manager/task/component/AbstractScheduledTask.java | 5 ++--- .../com/xiaojukeji/kafka/manager/web/MainApplication.java | 5 ++--- 2 files changed, 4 insertions(+), 6 deletions(-) diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/AbstractScheduledTask.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/AbstractScheduledTask.java index 564094d5..28c0e97d 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/AbstractScheduledTask.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/AbstractScheduledTask.java @@ -80,10 +80,9 @@ public abstract class AbstractScheduledTask implements Sch return true; } - LOGGER.error("modify scheduledCron failed, format invalid, scheduledName:{} scheduledCron:{}." - , scheduledName, scheduledCron); + LOGGER.error("modify scheduledCron failed, format invalid, scheduledName:{} scheduledCron:{}.", scheduledName, scheduledCron); if (existIfIllegal) { - System.exit(0); + throw new UnsupportedOperationException(String.format("scheduledName:%s scheduledCron:%s format invalid", scheduledName, scheduledCron)); } return false; } diff --git a/kafka-manager-web/src/main/java/com/xiaojukeji/kafka/manager/web/MainApplication.java b/kafka-manager-web/src/main/java/com/xiaojukeji/kafka/manager/web/MainApplication.java index 106d15f5..c5522a4f 100644 --- a/kafka-manager-web/src/main/java/com/xiaojukeji/kafka/manager/web/MainApplication.java +++ b/kafka-manager-web/src/main/java/com/xiaojukeji/kafka/manager/web/MainApplication.java @@ -3,7 +3,6 @@ package com.xiaojukeji.kafka.manager.web; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.boot.SpringApplication; -import org.springframework.boot.autoconfigure.EnableAutoConfiguration; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.web.servlet.ServletComponentScan; import org.springframework.scheduling.annotation.EnableAsync; @@ -17,7 +16,6 @@ import org.springframework.scheduling.annotation.EnableScheduling; @EnableAsync @EnableScheduling @ServletComponentScan -@EnableAutoConfiguration @SpringBootApplication(scanBasePackages = {"com.xiaojukeji.kafka.manager"}) public class MainApplication { private static final Logger LOGGER = LoggerFactory.getLogger(MainApplication.class); @@ -28,7 +26,8 @@ public class MainApplication { sa.run(args); LOGGER.info("MainApplication started"); } catch (Exception e) { - e.printStackTrace(); + LOGGER.error("start failed and application exit", e); + System.exit(1); } } }