enhance: fix skip msg log with empty position info (milvus-io#36626)

All skiped message position info was nil, should print BeginTs or MessageID instead. relate: milvus-io#36569 Signed-off-by: aoiasd <[email protected]>
bigsheeper · Oct 9, 2024 · 2c3a8b7 · 2c3a8b7
1 parent addced2
commit 2c3a8b7
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/mq/msgstream/mq_msgstream.go b/pkg/mq/msgstream/mq_msgstream.go
@@ -966,7 +966,8 @@ func (ms *MqTtMsgStream) Seek(ctx context.Context, msgPositions []*MsgPosition,
 						zap.Int64("source", tsMsg.SourceID()),
 						zap.String("type", tsMsg.Type().String()),
 						zap.Int("size", tsMsg.Size()),
-						zap.Any("position", tsMsg.Position()),
+						zap.Uint64("msgTs", tsMsg.BeginTs()),
+						zap.Uint64("posTs", mp.GetTimestamp()),
 					)
 				}
 			}