我正在尝试在 Kafka 消费者之间传播跨度,以使用OpenTracing 的 FollowsFrom 引用查看消息的处理历史。
我有一个生产者库,它目前有一个Produce(msg)
函数,我正在考虑将其签名迁移为Produce(ctx, msg)
,然后在生成它之前自动将 ctx 中的 span 上下文注入到 Kafka 消息头中。但是,我担心这不是正确的使用方式,context.Context
因为我只是在传播嵌入在 ctx 中的 SpanContext,而不是任何现有的截止日期。
这是正确的使用方式context.Context
还是我的 API 应该不同?