Perf: consumer callback is now executed as goroutine

asheswook · asheswook · commit edab5b7b48e4 · 2024-07-23T14:24:08.000+09:00
diff --git a/internal/queue/kafka/consumer.go b/internal/queue/kafka/consumer.go
@@ -25,7 +25,7 @@ func (c *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim saram
 				return nil
 			}
 
-			c.callback(msg)
+			go c.callback(msg)
 
 		case <-session.Context().Done():
 			return nil

Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@ func (c *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim saram`
`25`	`25`	`return nil`
`26`	`26`	`}`
`27`	`27`
`28`		`- c.callback(msg)`
	`28`	`+ go c.callback(msg)`
`29`	`29`
`30`	`30`	`case <-session.Context().Done():`
`31`	`31`	`return nil`