Skip to content

Commit

Permalink
consumer group: bugfix regex consuming (from v0.8.0+)
Browse files Browse the repository at this point in the history
v0.8.0 lost initializing the reSeen map in the group consumer, which
causes panics when consuming via regex as a group consumer.
  • Loading branch information
twmb committed Jun 29, 2021
1 parent 91fe77b commit 7ec0a45
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions pkg/kgo/consumer_group.go
Original file line number Diff line number Diff line change
Expand Up @@ -137,6 +137,8 @@ func (c *consumer) initGroup() {
ctx: ctx,
cancel: cancel,

reSeen: make(map[string]bool),

manageDone: make(chan struct{}),
cooperative: c.cl.cfg.cooperative(),
tps: newTopicsPartitions(),
Expand Down

0 comments on commit 7ec0a45

Please sign in to comment.