From a7c36047b8e585b506d652ff88d35c53f691e562 Mon Sep 17 00:00:00 2001 From: Zike Yang Date: Mon, 8 Dec 2025 17:26:35 +0800 Subject: [PATCH] fix: change producer reconnect error logs to warn logs --- 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 a6b83a8f83..06021eeadb 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--