(pulsar-client-go) branch master updated: fix: change producer reconnect error logs to warn logs (#1445)

[cr...@apache.org]

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

crossoverjie 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 25af763a fix: change producer reconnect error logs to warn logs (#1445)
25af763a is described below

commit 25af763adb2ec1062d634dcc75e870907bcbdefc
Author: Zike Yang <zi...@apache.org>
AuthorDate: Mon Jan 5 10:54:32 2026 +0800

    fix: change producer reconnect error logs to warn logs (#1445)
---
 pulsar/producer_partition.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
index a6b83a8f..06021eea 100755
--- a/pulsar/producer_partition.go
+++ b/pulsar/producer_partition.go
@@ -508,7 +508,6 @@ func (p *partitionProducer) reconnectToBroker(connectionClosed *connectionClosed
 			bo.Reset()
 			return struct{}{}, nil
 		}
-		p.log.WithError(err).Error("Failed to create producer at reconnect")
 		errMsg := err.Error()
 		if strings.Contains(errMsg, errMsgTopicNotFound) {
 			// when topic is deleted, we should give up reconnection.
@@ -534,6 +533,7 @@ func (p *partitionProducer) reconnectToBroker(connectionClosed *connectionClosed
 			p.doClose(errors.Join(ErrProducerFenced, err))
 			return struct{}{}, nil
 		}
+		p.log.WithError(err).Warn("Failed to reconnect to broker, will retry later.")
 
 		if maxRetry > 0 {
 			maxRetry--