propagated the context from sarama consumer group session into the log log.WithContext()

Kimbohlovette · Kimbohlovette · commit f50deea4c692 · 2024-03-23T14:56:25.000+01:00
diff --git a/src/accountingservice/kafka/consumer.go b/src/accountingservice/kafka/consumer.go
@@ -74,7 +74,7 @@ func (g *groupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim s
 				return err
 			}
 
-			g.log.WithContext(context.Background()).WithFields(logrus.Fields{
+			g.log.WithContext(session.Context()).WithFields(logrus.Fields{
 				"orderId":          orderResult.OrderId,
 				"messageTimestamp": message.Timestamp,
 				"messageTopic":     message.Topic,

Original file line number	Diff line number	Diff line change
`@@ -74,7 +74,7 @@ func (g *groupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim s`
`74`	`74`	`return err`
`75`	`75`	`}`
`76`	`76`
`77`		`- g.log.WithContext(context.Background()).WithFields(logrus.Fields{`
	`77`	`+ g.log.WithContext(session.Context()).WithFields(logrus.Fields{`
`78`	`78`	`"orderId": orderResult.OrderId,`
`79`	`79`	`"messageTimestamp": message.Timestamp,`
`80`	`80`	`"messageTopic": message.Topic,`