-
Notifications
You must be signed in to change notification settings - Fork 277
Open
Labels
type/bugSomething isn't workingSomething isn't working
Description
Before Creating the Bug Report
-
I found a bug, not just asking a question, which should be created in GitHub Discussions.
-
I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.
-
I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.
Programming Language of the Client
Go
Runtime Platform Environment
Any
RocketMQ Version of the Client/Server
Any
Run or Compiler Version
Any
Describe the Bug
rocketmq-clients/golang/producer_options.go
Line 155 in fd58dab
| ps.retryPolicy.MaxAttempts = retryPolicy.GetMaxAttempts() |
the setting sync will override the MaxAttempts, but in Java it is not. Actually the MaxAttempts should be controlled by the client
For java,
Line 111 in fd58dab
| return new ExponentialBackoffRetryPolicy(maxAttempts, |
Steps to Reproduce
Change MaxAttempts using WithMaxAttempts(1), then send message
What Did You Expect to See?
Should attempt less
What Did You See Instead?
Still attempts = 3
Additional Context
No response
Metadata
Metadata
Assignees
Labels
type/bugSomething isn't workingSomething isn't working