You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by "zzzming (via GitHub)" <gi...@apache.org> on 2023/11/24 16:44:34 UTC
[I] retry producer creation upon error after successful topic lookup [pulsar-client-go]
zzzming opened a new issue, #1138:
URL: https://github.com/apache/pulsar-client-go/issues/1138
#### Expected behavior
In the newPartitionProducer() function, there should be a retry of grabCnx(). It will be similar to the reconnectToBroker's grabCnx() retry logic.
Java producer has this retry logic.
#### Actual behavior
At the producer creation call, after a successful topic lookup at grabCnx() in producer_partition.go, if there is a network issue before the COMMAND to create producer sent, the grabCnx() will exit without retry.
We had frequent failures upon the initial producer creation.
#### Steps to reproduce
It's tricky to reproduce. But we observe the problem more frequently on Azure pod's initialization stage. After implementing the grabCnx() retry in the newPartitionProducer(), the problem has gone away. (Will do a PR)
#### System configuration
**Pulsar version**: 2.10
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org