0

我正在尝试在 Kafka 消费者之间传播跨度,以使用OpenTracing 的 FollowsFrom 引用查看消息的处理历史。

我有一个生产者库,它目前有一个Produce(msg)函数,我正在考虑将其签名迁移为Produce(ctx, msg),然后在生成它之前自动将 ctx 中的 span 上下文注入到 Kafka 消息头中。但是,我担心这不是正确的使用方式,context.Context因为我只是在传播嵌入在 ctx 中的 SpanContext,而不是任何现有的截止日期。

这是正确的使用方式context.Context还是我的 API 应该不同?

4

0 回答 0