diff --git a/internal/dataservice/server.go b/internal/dataservice/server.go
index 318b104de7e8efb12912e6ca942219ca08be9463..d6a3e60513d309191aed3d8772a2c1af560d36c9 100644
--- a/internal/dataservice/server.go
+++ b/internal/dataservice/server.go
@@ -188,7 +188,7 @@ func (s *Server) initSegmentInfoChannel() {
 }
 func (s *Server) initMsgProducer() error {
 	var err error
-	if s.ttMsgStream, err = s.msFactory.NewTtMsgStream(s.ctx); err != nil {
+	if s.ttMsgStream, err = s.msFactory.NewMsgStream(s.ctx); err != nil {
 		return err
 	}
 	s.ttMsgStream.AsConsumer([]string{Params.TimeTickChannelName}, Params.DataServiceSubscriptionName)