admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-29 06:55:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

[skip ci]Improve error message in rocksmq (#10195)

Browse Source 
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
This commit is contained in:
Xiangyu Wang 2021-10-19 17:52:42 +08:00 committed by GitHub
parent afa6eeecd7
commit 88a2b2b07c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/util/rocksmq/client/rocksmq/client_impl.go
View File

@ -57,7 +57,7 @@ func (c *client) CreateProducer(options ProducerOptions) (Producer, error) {
}
if reflect.ValueOf(c.server).IsNil() {
return nil, newError(0, "rmq server is nil")
return nil, newError(0, "Rmq server is nil")
}
// Create a topic in rocksmq, ignore if topic exists
err = c.server.CreateTopic(options.Topic)
@ -72,7 +72,7 @@ func (c *client) CreateProducer(options ProducerOptions) (Producer, error) {
func (c *client) Subscribe(options ConsumerOptions) (Consumer, error) {
// Create a consumer
if reflect.ValueOf(c.server).IsNil() {
return nil, newError(0, "rmq server is nil")
return nil, newError(0, "Rmq server is nil")
}
if exist, con := c.server.ExistConsumerGroup(options.Topic, options.SubscriptionName); exist {
log.Debug("ConsumerGroup already existed", zap.Any("topic", options.Topic), zap.Any("SubscriptionName", options.SubscriptionName))