diff --git a/internal/msgstream/mq_msgstream_test.go b/internal/msgstream/mq_msgstream_test.go
index a22220a602..024eb3e62b 100644
--- a/internal/msgstream/mq_msgstream_test.go
+++ b/internal/msgstream/mq_msgstream_test.go
@@ -323,7 +323,7 @@ func TestStream_PulsarMsgStream_DeleteRepackFunc(t *testing.T) {
 			SourceID:  1,
 		},
 		CollectionName: "Collection",
-		ChannelID:      "1",
+		ShardName:      "chan-1",
 		Timestamp:      Timestamp(1),
 		ExprPlan:       []byte{},
 	}
diff --git a/internal/msgstream/repack_func.go b/internal/msgstream/repack_func.go
index 56a2bf482b..688165d44b 100644
--- a/internal/msgstream/repack_func.go
+++ b/internal/msgstream/repack_func.go
@@ -102,7 +102,7 @@ func DeleteRepackFunc(tsMsgs []TsMsg, hashKeys [][]int32) (map[int32]*MsgPack, e
 				SourceID:  deleteRequest.Base.SourceID,
 			},
 			CollectionName: deleteRequest.CollectionName,
-			ChannelID:      deleteRequest.ChannelID,
+			ShardName:      deleteRequest.ShardName,
 			Timestamp:      deleteRequest.Timestamp,
 			ExprPlan:       deleteRequest.ExprPlan,
 		}