From f9508a4851a0feabb40447c136e42e3dabd92237 Mon Sep 17 00:00:00 2001 From: XuanYang-cn Date: Mon, 15 Jan 2024 11:40:51 +0800 Subject: [PATCH] fix: Remove logging data when logging skip msg (#29707) See also: #29696 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 386506eb37..a0dd919a55 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()), + ) } } }