From 62d02b429700433f3ea2f9492bfe5d78d6b8e68d Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Fri, 8 May 2020 17:57:16 +0300 Subject: [PATCH] broker/segmentio: fix kafka topic in publication Signed-off-by: Vasiliy Tolstov --- segmentio.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/segmentio.go b/segmentio.go index 577e250..0599e5f 100644 --- a/segmentio.go +++ b/segmentio.go @@ -324,7 +324,7 @@ func (h *cgHandler) run(ctx context.Context) { var m broker.Message eh := h.brokerOpts.ErrorHandler offsets[msg.Topic][msg.Partition] = msg.Offset - p := &publication{generation: h.generation, m: &m, offsets: offsets} + p := &publication{topic: msg.Topic, generation: h.generation, m: &m, offsets: offsets} if err := h.brokerOpts.Codec.Unmarshal(msg.Value, &m); err != nil { p.err = err