WinChua opened a new pull request #732: URL: https://github.com/apache/pulsar-client-go/pull/732
Fixes #731 ### Motivation As the #731 has show, some msg maybe sent after the reconnection of the producer, no mater the msg has been sent or not, which will cause that the same msg will be sent and consumed mulit time at the application view. ### Modifications A sent flag was added to [pendingItem](https://github.com/WinChua/pulsar-client-go/blob/42af6818c03cf6803289cdc5706eea09d82ec95f/pulsar/producer_partition.go#L520) to indicated that the corresponding buffer has been sent successfully. And in the resend logic the sent item will not be sent again. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
