Skip to content

Commit 3daa659

Browse files
authored
[ISSUE #694] Fix typos
Co-authored-by: liuweiyi <liuweiyi@cmss.chinamobile.com>
1 parent c688c19 commit 3daa659

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

consumer/offset_store.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -301,15 +301,15 @@ func (r *remoteBrokerOffsetStore) read(mq *primitive.MessageQueue, t readType) i
301301
case _ReadFromStore:
302302
off, err := r.fetchConsumeOffsetFromBroker(r.group, mq)
303303
if err != nil {
304-
rlog.Error("fecth offset of mq from broker error", map[string]interface{}{
304+
rlog.Error("fetch offset of mq from broker error", map[string]interface{}{
305305
rlog.LogKeyConsumerGroup: r.group,
306306
rlog.LogKeyMessageQueue: mq.String(),
307307
rlog.LogKeyUnderlayError: err,
308308
})
309309
r.mutex.RUnlock()
310310
return -1
311311
}
312-
rlog.Warning("fecth offset of mq from broker success", map[string]interface{}{
312+
rlog.Warning("fetch offset of mq from broker success", map[string]interface{}{
313313
rlog.LogKeyConsumerGroup: r.group,
314314
rlog.LogKeyMessageQueue: mq.String(),
315315
"offset": off,

0 commit comments

Comments
 (0)