gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(common): correct kafka monitor error log for blobstore

Browse Source 
Signed-off-by: zhangjianwei2 <zhangjianwei2_yewu@cmss.chinamobile.com>
This commit is contained in:
zhangjianwei2 2025-09-18 21:56:10 +08:00 committed by 梁曟風
parent 69fae6c622
commit b6c48c5a4e
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
blobstore/common/kafka/monitor.go
View File

@ -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
}