|
|
@@ -156,7 +156,7 @@ func RunWaitingCluster() {
|
|
|
infra.GlobalLogger.Infof("字符串 %v 转整数失败，错误信息为： %v", val, err)
|
|
|
continue
|
|
|
}
|
|
|
- infra.GlobalLogger.Infof("初始化偏移量【%v】=【%v】", offsetKey, offset)
|
|
|
+ infra.GlobalLogger.Infof("当前任务使用偏移量【%v】", offset)
|
|
|
}
|
|
|
// 取出偏移量后将缓存中的加一，给下个任务使用。
|
|
|
_, err = infra.GlobalRedisClient.Incr(offsetKey).Result()
|
|
|
@@ -164,7 +164,7 @@ func RunWaitingCluster() {
|
|
|
infra.GlobalLogger.Infof("偏移量 %v 加一失败，错误信息为： %v", offsetKey, err)
|
|
|
continue
|
|
|
}
|
|
|
- infra.GlobalLogger.Infof("偏移量【%v】加一", offsetKey)
|
|
|
+ infra.GlobalLogger.Infof("偏移量【%v】加一给下个任务使用。", offsetKey)
|
|
|
|
|
|
// --------------- 发送 kafka 消息（获取偏移量和分区） ---------------
|
|
|
// 获取任务消息转json
|
