@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的异步监听失败");
}
}



