From d7abb27eac70f10ece8b574689c856e46fa7ad2b Mon Sep 17 00:00:00 2001 From: JasonHu520 Date: Wed, 16 Oct 2024 15:13:32 +0800 Subject: [PATCH] refactor(scheduler): update log level for kafka message @formatter:off Signed-off-by: JasonHu520 --- blobstore/scheduler/base/kafka_consumer_group.go | 2 +- blobstore/scheduler/blob_deleter.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/blobstore/scheduler/base/kafka_consumer_group.go b/blobstore/scheduler/base/kafka_consumer_group.go index 535e29985..6ca8720dc 100644 --- a/blobstore/scheduler/base/kafka_consumer_group.go +++ b/blobstore/scheduler/base/kafka_consumer_group.go @@ -100,7 +100,7 @@ func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, clai select { case message = <-claim.Messages(): if message == nil { - span.Warnf("no message for consume and continue") + span.Debug("no message for consume and continue") continue } diff --git a/blobstore/scheduler/blob_deleter.go b/blobstore/scheduler/blob_deleter.go index e27dae93f..b3bab95a5 100644 --- a/blobstore/scheduler/blob_deleter.go +++ b/blobstore/scheduler/blob_deleter.go @@ -515,7 +515,7 @@ func (mgr *BlobDeleteMgr) consume(item *delBlobRet, consumerPause base.ConsumerP now := time.Now().UTC() if now.Sub(time.Unix(item.delMsg.Time, 0)) < mgr.safeDelayTime { sleepDuration := mgr.delayDuration(item.delMsg.Time) - span.Warnf("blob is protected: until[%+v], sleep[%+v]", time.Unix(item.delMsg.Time, 0).Add(mgr.safeDelayTime), sleepDuration) + span.Debugf("blob is protected: until[%+v], sleep[%+v]", time.Unix(item.delMsg.Time, 0).Add(mgr.safeDelayTime), sleepDuration) ok := sleep(sleepDuration, consumerPause) if !ok { item.status = DeleteStatusUndo