Closed chazex closed 5 months ago
kratos-transport up в type headerCarrier struct{} add Keys() []string Values(key string) []string
kratos-transport up в type headerCarrier struct{} add Keys() []string Values(key string) []string
already fixed
@chazex 请问如何通过 context
来设置优雅退出?
当我发现 server.Stop()
不生效时,我修改了取消订阅 s.reader.Close()
, 但是同样会有二次消费的问题。
Hi, 我现在使用Kratos框架,server使用的是 kratos-transport的kafka。 有如下疑问: