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