diff --git a/protocol/grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go b/protocol/grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go
index ae9cc72d09722e28a8120e4741f951d66422fda0..b34ecfaa95a056547bda56734271c7d840c5e1dd 100644
--- a/protocol/grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go
+++ b/protocol/grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go
@@ -240,7 +240,7 @@ func (g *dubboGrpc) generateClientSignature(servName string, method *pb.MethodDe
 	}
 	respName := "out *" + g.typeName(method.GetOutputType())
 	if method.GetServerStreaming() || method.GetClientStreaming() {
-		respName = "out * "+ servName + "_" + generator.CamelCase(origMethName) + "Client"
+		respName =  servName + "_" + generator.CamelCase(origMethName) + "Client"
 	}
 	return fmt.Sprintf("%s func(ctx %s.Context%s, %s) error", methName, contextPkg, reqArg, respName)
 }
diff --git a/registry/consul/registry.go b/registry/consul/registry.go
index 78caa5a183c407bd5651141e23880499702baace..b92e335fdb69f82210d2977789902eb6123201b8 100644
--- a/registry/consul/registry.go
+++ b/registry/consul/registry.go
@@ -56,9 +56,6 @@ type consulRegistry struct {
 	// Done field represents whether
 	// consul registry is closed.
 	done chan struct{}
-
-	// time wait when destroy
-	timeOut time.Duration
 }
 
 func newConsulRegistry(url *common.URL) (registry.Registry, error) {