Skip to content

Commit 7b9c99d

Browse files
authored
fix typo (#1302)
1 parent ebca72e commit 7b9c99d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

consumergroup.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -527,7 +527,7 @@ func (g *Generation) partitionWatcher(interval time.Duration, topic string) {
527527
case err == nil, errors.Is(err, UnknownTopicOrPartition):
528528
if len(ops) != oParts {
529529
g.log(func(l Logger) {
530-
l.Printf("Partition changes found, reblancing group: %v.", g.GroupID)
530+
l.Printf("Partition changes found, rebalancing group: %v.", g.GroupID)
531531
})
532532
return
533533
}

0 commit comments

Comments
 (0)