@@ -68,7 +68,7 @@ public class TestJob implements Job {
6868// 2、在类上添加@Task注解,并且配置好信息,指定为广播抢占模式;
6969// 效果:KS集群中,每5秒,每台KS主机都会输出 "测试定时任务运行中";
7070@Task (name = " TestJob" ,
71- description = " 测试定时任务" ,
71+ description = " 测试定时任务" ,
7272 cron = " */5 * * * * ?" ,
7373 autoRegister = true ,
7474 consensual = ConsensualEnum . BROADCAST , // 这里一定要设置为BROADCAST
@@ -103,7 +103,7 @@ public class TestJob implements Job {
103103// 2、在类上添加@Task注解,并且配置好信息,指定为广播模式;
104104// 效果:在本样例中,每隔1分钟ks会将所有的kafka集群列表在ks集群主机内均衡拆分,每台主机会将分发到自身的Kafka集群依次执行processSubTask方法,实现KS集群的任务协同处理。
105105@Task (name = " kmJobTask" ,
106- description = " km job 模块调度执行任务" ,
106+ description = " km job 模块调度执行任务" ,
107107 cron = " 0 0/1 * * * ? *" ,
108108 autoRegister = true ,
109109 consensual = ConsensualEnum . BROADCAST ,
@@ -230,7 +230,7 @@ public abstract class AbstractClusterPhyDispatchTask extends AbstractDispatchTas
230230```java
231231// 加上@Task注解,并配置任务执行信息
232232@Task (name = " kmJobTask" ,
233- description = " km job 模块调度执行任务" ,
233+ description = " km job 模块调度执行任务" ,
234234 cron = " 0 0/1 * * * ? *" ,
235235 autoRegister = true ,
236236 consensual = ConsensualEnum . BROADCAST ,
0 commit comments