We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Hi, 我现在使用Kratos框架,server使用的是 kratos-transport的kafka。 有如下疑问:
The text was updated successfully, but these errors were encountered:
kratos-transport up в type headerCarrier struct{} add Keys() []string Values(key string) []string
Sorry, something went wrong.
already fixed
@chazex 请问如何通过 context 来设置优雅退出? 当我发现 server.Stop() 不生效时,我修改了取消订阅 s.reader.Close(), 但是同样会有二次消费的问题。
context
server.Stop()
s.reader.Close()
No branches or pull requests
Hi,
我现在使用Kratos框架,server使用的是 kratos-transport的kafka。
有如下疑问:
The text was updated successfully, but these errors were encountered: