This is an automated email from the ASF dual-hosted git repository.

jianhaixu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new ac29854  fix panic when pullconsumer started.
     new f9b98f4  Merge pull request #524 from Demogorgon314/master
ac29854 is described below

commit ac298546b08c1e5198629bf6f5f2f78990a5451d
Author: Demogorgon314 <[email protected]>
AuthorDate: Thu Aug 13 21:40:20 2020 +0800

    fix panic when pullconsumer started.
---
 consumer/pull_consumer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go
index 0523f08..3a54194 100644
--- a/consumer/pull_consumer.go
+++ b/consumer/pull_consumer.go
@@ -81,6 +81,7 @@ func NewPullConsumer(options ...Option) 
(*defaultPullConsumer, error) {
                return nil, errors.Wrap(err, "new Namesrv failed.")
        }
 
+       defaultOpts.Namesrv = srvs
        dc := &defaultConsumer{
                client:        
internal.GetOrNewRocketMQClient(defaultOpts.ClientOptions, nil),
                consumerGroup: defaultOpts.GroupName,

Reply via email to