(pulsar-client-go) branch master updated: [Fix][Producer] Reconnection backoff logic for producer (#1125)

[ti...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 64c87a0a [Fix][Producer] Reconnection backoff logic for producer (#1125)
64c87a0a is described below

commit 64c87a0a6895ceaeb14ac39432adafbef54d007e
Author: gunli <24...@qq.com>
AuthorDate: Sat Nov 4 11:14:07 2023 +0800

    [Fix][Producer] Reconnection backoff logic for producer (#1125)
    
    Co-authored-by: gunli <gu...@tencent.com>
---
 pulsar/producer_partition.go | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
index e214979d..8608df3d 100755
--- a/pulsar/producer_partition.go
+++ b/pulsar/producer_partition.go
@@ -396,6 +396,11 @@ func (p *partitionProducer) reconnectToBroker() {
 		maxRetry = int(*p.options.MaxReconnectToBroker)
 	}
 
+	var (
+		delayReconnectTime time.Duration
+		defaultBackoff     = internal.DefaultBackoff{}
+	)
+
 	for maxRetry != 0 {
 		if p.getProducerState() != producerReady {
 			// Producer is already closing
@@ -403,11 +408,6 @@ func (p *partitionProducer) reconnectToBroker() {
 			return
 		}
 
-		var (
-			delayReconnectTime time.Duration
-			defaultBackoff     = internal.DefaultBackoff{}
-		)
-
 		if p.options.BackoffPolicy == nil {
 			delayReconnectTime = defaultBackoff.Next()
 		} else {