diff --git a/internal/dataservice/param.go b/internal/dataservice/param.go
index 9a574924a8..3455954985 100644
--- a/internal/dataservice/param.go
+++ b/internal/dataservice/param.go
@@ -182,7 +182,7 @@ func (p *ParamTable) initSegmentInfoChannelName() {
 
 func (p *ParamTable) initDataServiceSubscriptionName() {
 	var err error
-	p.DataServiceSubscriptionName, err = p.Load("msgChannel.chanNamePrefix.dataServiceSubNamePrefix")
+	p.DataServiceSubscriptionName, err = p.Load("msgChannel.subNamePrefix.dataServiceSubNamePrefix")
 	if err != nil {
 		panic(err)
 	}
diff --git a/internal/dataservice/server.go b/internal/dataservice/server.go
index 4844b84110..056aaf773f 100644
--- a/internal/dataservice/server.go
+++ b/internal/dataservice/server.go
@@ -122,14 +122,14 @@ func (s *Server) Start() error {
 	}
 	s.ddHandler = newDDHandler(s.meta, s.segAllocator)
 	s.initSegmentInfoChannel()
-	if err = s.initMsgProducer(); err != nil {
-		return err
-	}
 	if err = s.loadMetaFromMaster(); err != nil {
 		return err
 	}
 	s.startServerLoop()
 	s.waitDataNodeRegister()
+	if err = s.initMsgProducer(); err != nil {
+		return err
+	}
 	s.state.Store(internalpb2.StateCode_HEALTHY)
 	log.Println("start success")
 	return nil