Skip to content

Commit

Permalink
Update producer.go
Browse files Browse the repository at this point in the history
  • Loading branch information
pellared committed Jul 12, 2021
1 parent bf0f005 commit cabb771
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -168,7 +168,7 @@ func WrapAsyncProducer(saramaConfig *sarama.Config, p sarama.AsyncProducer, opts
span: span,
}

// Remember specific metadata with span id
// Remember metadata using span ID as a cache key
msg.Metadata = span.SpanContext().SpanID()
if saramaConfig.Producer.Return.Successes {
mtx.Lock()
Expand Down

0 comments on commit cabb771

Please sign in to comment.