wlhjom opened a new issue, #1137:
URL: https://github.com/apache/rocketmq-clients/issues/1137

   ### Before Creating the Bug Report
   
   - [x] I found a bug, not just asking a question, which should be created in 
[GitHub Discussions](https://github.com/apache/rocketmq-clients/discussions).
   
   - [x] I have searched the [GitHub 
Issues](https://github.com/apache/rocketmq-clients/issues) and [GitHub 
Discussions](https://github.com/apache/rocketmq-clients/discussions)  of this 
repository and believe that this is not a duplicate.
   
   - [x] I have confirmed that this bug belongs to the current repository, not 
other repositories of RocketMQ.
   
   
   ### Programming Language of the Client
   
   Java
   
   ### Runtime Platform Environment
   
   rocketmq5.3。proxy模式
   
   ### RocketMQ Version of the Client/Server
   
   5.3
   
   ### Run or Compiler Version
   
   _No response_
   
   ### Describe the Bug
   
    问题: Golang client 在proxy重启后,会丢失Client Settings,导致心跳和Pop消息的时候因为空指针失败。
    原因:  应该是由于Settings 不能及时同步到重启后的Proxy导致的。
                go func() {
                time.Sleep(cm.opts.SYNC_SETTINGS_DELAY)
                cm.syncSettings()
                ticker.Tick(cm.syncSettings, (cm.opts.SYNC_SETTINGS_PERIOD), 
cm.done)
        }()
              其中SYNC_SETTINGS_PERIOD 
是5分钟同步一次。那么由于proxy重启后5分钟内,心跳和消费等请求无法正常发送。是否可以配置此参数,可以设置同步间隔,或者在消费,生产消息,ACK等,遇到链接错误,可以自动同步一下Settings
 ?
   
   ### Steps to Reproduce
   
   1. 正常启动golang client 客户端
   2. 过一段时间后,将proxy重启,复现问题。
   
   ### What Did You Expect to See?
   
   在proxy正常重启或故障重启后,不影响消费,生产等,把影响降到最低。
   
   ### What Did You See Instead?
   
   在proxy正常重启或故障重启后,不影响消费,生产等,把影响降到最低。
   
   ### Additional Context
   
   _No response_


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to