fix: remove mutex lock causing deadlocks when Consumer.Return.Errors …

…is enabled
stevenvdr · Dec 31, 2019 · 8847ac5 · 8847ac5
1 parent d514254
commit 8847ac5
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/consumer_group.go b/consumer_group.go
@@ -430,9 +430,6 @@ func (c *consumerGroup) handleError(err error, topic string, partition int32) {
 		return
 	}
 
-	c.lock.Lock()
-	defer c.lock.Unlock()
-
 	select {
 	case <-c.closed:
 		//consumer is closed