Change params

Signed-off-by: Nsunby <bingyi.sun@zilliz.com>

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)
 	}

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