Merge pull request #79 from unistack-org/kgo-context
propogate context to kgo record
This commit is contained in:
commit
7390973672
2
kgo.go
2
kgo.go
@ -262,7 +262,7 @@ func (k *kBroker) publish(ctx context.Context, msgs []*broker.Message, opts ...b
|
||||
}
|
||||
|
||||
for _, msg := range msgs {
|
||||
rec := &kgo.Record{Key: key}
|
||||
rec := &kgo.Record{Context: ctx, Key: key}
|
||||
rec.Topic, _ = msg.Header.Get(metadata.HeaderTopic)
|
||||
if k.opts.Codec.String() == "noop" {
|
||||
rec.Value = msg.Body
|
||||
|
Loading…
x
Reference in New Issue
Block a user