@@ -241,7 +241,7 @@ func RunWaitingCluster() {
infra.GlobalLogger.Infof("发送任务消息 %v 失败，错误信息为： %v", msg, err)
continue
}
- infra.GlobalLogger.Infof("发送任务消息成功，话题为【%v】，偏移量为【%v】。", topic, offset)
+ infra.GlobalLogger.Infof("发送任务消息成功，话题为【%v】，偏移量为【%v】,消息为【%v】", topic, offset, taskJson)
// 如果新算法需要导入
if !algorithmExist {
