diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/biz/CalKafkaTopicBill.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/biz/CalKafkaTopicBill.java index 54529706d9363cc2eb833a7f6b34e6fc6aa9b603..ee9797c6b7273f305aa43c96913557b2b89d9157 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/biz/CalKafkaTopicBill.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/biz/CalKafkaTopicBill.java @@ -25,7 +25,7 @@ import java.util.*; * @author zengqiao * @date 20/5/11 */ -@CustomScheduled(name = "calKafkaBill", cron = "0 0 1 * * *", threadNum = 1, description = "计算账单") +@CustomScheduled(name = "calKafkaBill", cron = "0 0 1 * * ?", threadNum = 1, description = "计算账单") public class CalKafkaTopicBill extends AbstractScheduledTask { private static final Logger LOGGER = LoggerFactory.getLogger(CalKafkaTopicBill.class); diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishCGData.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishCGData.java index 7bcec2df5426c41d5cac56ea49d0ca35366ea230..ceedff80ffffb3700dd5aa7b9ae856e234996f48 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishCGData.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishCGData.java @@ -31,7 +31,7 @@ import java.util.concurrent.FutureTask; * @author zengqiao * @date 20/9/14 */ -@CustomScheduled(name = "newCollectAndPublishCGData", cron = "30 0/1 * * * *", threadNum = 10, description = "收集并发布消费者指标数据") +@CustomScheduled(name = "newCollectAndPublishCGData", cron = "30 0/1 * * * ?", threadNum = 10, description = "收集并发布消费者指标数据") public class CollectAndPublishCGData extends AbstractScheduledTask { private static final Logger LOGGER = LoggerFactory.getLogger(CollectAndPublishCGData.class);