#133 fix race.

2024-04-19 13:16:23 +03:00 · 2024-04-19 13:16:23 +03:00 · ceae272ca8
commit ceae272ca8
parent 1f4cf11afe
1 changed files with 2 additions and 0 deletions
--- a/subscriber.go
+++ b/subscriber.go
@ -186,7 +186,9 @@ func (s *subscriber) assigned(_ context.Context, c *kgo.Client, assigned map[str
 				kopts:   s.kopts,
 				opts:    s.opts,
 			}
+			s.Lock()
 			s.consumers[tp{topic, partition}] = pc
+			s.Unlock()
 			go pc.consume()
 		}
 	}