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
内部带timeout 的 pub函数,好像只是用了 config里的timeout,没有在对外暴露的 Publish函数里提供timeout 参数。这是为什么呢,有什么考虑吗?
`
func (self *TopicProducerMgr) doCommandWithRetry(topic string, partitionKey []byte, commandFunc CmdFuncT) ([]byte, error) { return self.doCommandWithTimeoutAndRetry(topic, partitionKey, 0, 3, commandFunc) } `
The text was updated successfully, but these errors were encountered:
为什么不加一个 带有timeout参数的 publish函数
Sorry, something went wrong.
目前是通过config配置全局控制pub timeout的, 可以考虑加一个
No branches or pull requests
内部带timeout 的 pub函数,好像只是用了 config里的timeout,没有在对外暴露的 Publish函数里提供timeout 参数。这是为什么呢,有什么考虑吗?
`
producer.go line 1671
func (self *TopicProducerMgr) doCommandWithRetry(topic string, partitionKey []byte,
commandFunc CmdFuncT) ([]byte, error) {
return self.doCommandWithTimeoutAndRetry(topic, partitionKey, 0, 3, commandFunc)
}
`
The text was updated successfully, but these errors were encountered: