From b6c48c5a4e2a1ec94b927f44db27ede01464932e Mon Sep 17 00:00:00 2001 From: zhangjianwei2 Date: Thu, 18 Sep 2025 21:56:10 +0800 Subject: [PATCH] fix(common): correct kafka monitor error log for blobstore Signed-off-by: zhangjianwei2 --- blobstore/common/kafka/monitor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/blobstore/common/kafka/monitor.go b/blobstore/common/kafka/monitor.go index d32f21d54..e0c80f491 100644 --- a/blobstore/common/kafka/monitor.go +++ b/blobstore/common/kafka/monitor.go @@ -171,7 +171,7 @@ func (monitor *Monitor) loopAcquireKafkaOffset() { case <-ticker.C: offsets, err := monitor.kafkaAdmCli.ListConsumerGroupOffsets(groupID, map[string][]int32{monitor.topic: monitor.pids}) if err != nil { - log.Errorf("get consume offset failed: topic[%s], pids[%+v]", monitor.topic, monitor.pids) + log.Errorf("get consume offset failed: topic[%s], pids[%+v], err[%+v]", monitor.topic, monitor.pids, err) continue }