fix: [cherry-pick]Remove logging data when logging skip msg (#29708)

See also: #29696 pr: #29707 Signed-off-by: yangxuan <[email protected]>
milvus-io · Jan 15, 2024 · 962b3ea · 962b3ea
1 parent 58b9b8f
commit 962b3ea
Showing 1 changed file with 6 additions and 1 deletion.
diff --git 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()),
+					)
 				}
 			}
 		}