@SpringBootApplication @EnableScheduling public class SpringBootApplication { public static void main(String[] args) { SpringApplication.run(SpringBootApplication.class, args); } }
@Component @Slf4j public class AppRunner implements CommandLineRunner { @Override public void run(String... args) { log.info("启动执行"); } @Scheduled(cron = "0/30 * * * * ?") public void keepalive() { log.info("该方法的作用在于保持服务的运行,避免kafka的异步监听失败"); } }