diff --git a/internal/startrpc/start.go b/internal/startrpc/start.go
index 18fe7cef4..17afcc7a9 100644
--- a/internal/startrpc/start.go
+++ b/internal/startrpc/start.go
@@ -59,11 +59,16 @@ func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(c
 			}
 		}
 	}()
+
+	err = rpcFn(zkClient, srv)
+	if err != nil {
+		return utils.Wrap1(err)
+	}
 	err = srv.Serve(listener)
 	if err != nil {
 		return utils.Wrap1(err)
 	}
-	return rpcFn(zkClient, srv)
+	return nil
 }
 
 //func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error, options ...grpc.ServerOption) error {
diff --git a/pkg/common/mw/rpc.go b/pkg/common/mw/rpc.go
index f9004b648..a1d75233a 100644
--- a/pkg/common/mw/rpc.go
+++ b/pkg/common/mw/rpc.go
@@ -64,10 +64,13 @@ func rpcClientInterceptor(ctx context.Context, method string, req, reply interfa
 	if ok {
 		md.Append(constant.OpUserID, opUserID)
 	}
+	log.Info("", "rpc come here")
 	err = invoker(metadata.NewOutgoingContext(ctx, md), method, req, reply, cc, opts...)
 	if err == nil {
 		return nil
 	}
+	log.Info("", "rpc come here err")
+
 	rpcErr, ok := err.(interface{ GRPCStatus() *status.Status })
 	if !ok {
 		return errs.NewCodeError(errs.DefaultOtherError, err.Error()).Wrap()