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()),
+					)
 				}
 			}
 		}