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 <[email protected]>
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--
