From 962b3ea5fac1fe660524808768362f1ce82da94c Mon Sep 17 00:00:00 2001 From: XuanYang-cn Date: Mon, 15 Jan 2024 17:46:53 +0800 Subject: [PATCH] fix: [cherry-pick]Remove logging data when logging skip msg (#29708) See also: #29696 pr: #29707 Signed-off-by: yangxuan --- pkg/mq/msgstream/mq_msgstream.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/pkg/mq/msgstream/mq_msgstream.go b/pkg/mq/msgstream/mq_msgstream.go index 8210bd0bbe..6642f517f2 100644 --- a/pkg/mq/msgstream/mq_msgstream.go +++ b/pkg/mq/msgstream/mq_msgstream.go @@ -915,7 +915,12 @@ func (ms *MqTtMsgStream) Seek(ctx context.Context, msgPositions []*msgpb.MsgPosi }) ms.chanMsgBuf[consumer] = append(ms.chanMsgBuf[consumer], tsMsg) } else { - log.Info("skip msg", zap.Any("msg", tsMsg)) + log.Info("skip msg", + zap.Int64("source", tsMsg.SourceID()), + zap.String("type", tsMsg.Type().String()), + zap.Int("size", tsMsg.Size()), + zap.Any("position", tsMsg.Position()), + ) } } }