Trace takes a kafka.Writer and returns a decorated Writer.
(writer *kafka.Writer, tracer opentracing.Tracer, opts ...WriterOption)
| 30 | |
| 31 | // Trace takes a kafka.Writer and returns a decorated Writer. |
| 32 | func Trace(writer *kafka.Writer, tracer opentracing.Tracer, opts ...WriterOption) *Writer { |
| 33 | w := &Writer{ |
| 34 | Writer: writer, |
| 35 | tracer: tracer, |
| 36 | } |
| 37 | for _, f := range opts { |
| 38 | f(w) |
| 39 | } |
| 40 | return w |
| 41 | } |
| 42 | |
| 43 | // WriteMessages writes a batch of messages to the kafka topic configured on this |
| 44 | // writer. Each message written has been injected tracing headers. The upstream |