in kafka/metrics.go [600:611]
func attributesFromRecord(r *kgo.Record, extra ...attribute.KeyValue) []attribute.KeyValue {
attrs := make([]attribute.KeyValue, 0, 5) // Preallocate 5 elements.
attrs = append(attrs, semconv.MessagingSystem("kafka"))
attrs = append(attrs, extra...)
for _, v := range r.Headers {
if v.Key == "traceparent" { // Ignore traceparent.
continue
}
attrs = append(attrs, attribute.String(v.Key, string(v.Value)))
}
return attrs
}