enhance: change message position print

Signed-off-by: xiaofanluan <[email protected]>

pkg/mq/msgstream/mq_msgstream.go

@@ -966,7 +966,7 @@ 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.String("position", MsgPositionToString(tsMsg.Position())),
 					)
 				}
 			}

pkg/mq/msgstream/msgstream.go

@@ -18,6 +18,7 @@ package msgstream
 
 import (
 	"context"
+	"fmt"
 
 	"github.com/milvus-io/milvus-proto/go-api/v2/msgpb"
 	"github.com/milvus-io/milvus/pkg/mq/common"
@@ -48,6 +49,16 @@ type MsgPack struct {
 	EndPositions   []*MsgPosition
 }
 
+func MsgPositionToString(m *MsgPosition) string {
+	return fmt.Sprintf(
+		"MsgPosition{ChannelName: %s, MsgID: %x, MsgGroup: %s, Timestamp: %d}",
+		m.ChannelName,
+		m.MsgID,
+		m.MsgGroup,
+		m.Timestamp,
+	)
+}
+
 // RepackFunc is a function type which used to repack message after hash by primary key
 type RepackFunc func(msgs []TsMsg, hashKeys [][]int32) (map[int32]*MsgPack, error)