From 33cfb2ba2f03b65d1eb6f73ab564e32f157c60a6 Mon Sep 17 00:00:00 2001
From: congqixia <congqi.xia@zilliz.com>
Date: Thu, 27 Jul 2023 13:57:12 +0800
Subject: [PATCH] Fix MsgPack from mq msgstream ts not set (#25926)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
---
 pkg/mq/msgstream/mq_msgstream.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pkg/mq/msgstream/mq_msgstream.go b/pkg/mq/msgstream/mq_msgstream.go
index e70d7c1c49..2d4706ef1a 100644
--- a/pkg/mq/msgstream/mq_msgstream.go
+++ b/pkg/mq/msgstream/mq_msgstream.go
@@ -398,6 +398,8 @@ func (ms *mqMsgStream) receiveMsg(consumer mqwrapper.Consumer) {
 				Msgs:           []TsMsg{tsMsg},
 				StartPositions: []*msgpb.MsgPosition{tsMsg.Position()},
 				EndPositions:   []*msgpb.MsgPosition{tsMsg.Position()},
+				BeginTs:        tsMsg.BeginTs(),
+				EndTs:          tsMsg.EndTs(),
 			}
 			select {
 			case ms.receiveBuf <- &msgPack: