Tony.Chen

可以加个 origin: service_name，判断这个错误是从那里返回的，当origin为空时通过 WithMetadata("origin": serviceName) 进行带上

```go type Message interface { Key() string Value() []byte Header() map[string]string Ack() error Nack() error } type Handler func(context.Context, Message) error type Event interface { Send(ctx context.Context, key string, value...

Right, because it's synchronous, I haven't thought of a good way.

This can be implemented via the standard library HTTP Cache Handler and integrated into HTTP Filters, for example: ```go http.NewServer(http.Filter(cacheHandler)) ```

please `go mod tidy`

@uther518 Hello, can help merge the master

I think this is a very simple HTTP middleware, but it seems to be very complicated to implement.

生成插件： protoc-gen-grpc protoc-gen-http protoc-gen-kratos ```go pb.RegisterGreeterHTTPServer(httpServer) pb.RegisterGreeterServer(grpcServer) func RegisterGreeterKratosServer(srv grpc.Server) { // build middleware config srv.RegisterMiddleware(`yaml config`) } ``` 可以通过复写下注册方法，传递 kratos server 进来下

是的，这个可以支持 grpc service config，以及 middleware config，用户配置app.yaml 就可以了完成配置了

可以帮直接提个pr？