Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

producer.sendAsync is interrupted by client.close() #11780

Open
geomagilles opened this issue Aug 25, 2021 · 3 comments
Open

producer.sendAsync is interrupted by client.close() #11780

geomagilles opened this issue Aug 25, 2021 · 3 comments
Labels
lifecycle/stale type/bug The PR fixed a bug or issue reported a bug

Comments

@geomagilles
Copy link
Contributor

geomagilles commented Aug 25, 2021

Describe the bug
If the client closes while sendAsync() is processed, the message is lost.

To Reproduce
see https://github.com/infiniticio/pulsar-bug-clientAsync

Expected behavior
The message should be sent before actually closing the client (https://apache-pulsar.slack.com/archives/C5Z4T36F7/p1629752614463900?thread_ts=1629723649.441700&cid=C5Z4T36F7)

Additional context
none

@avirlrma
Copy link

avirlrma commented Aug 31, 2021

Hi folks,

Can I take this up?

@codelipenghui
Copy link
Contributor

The issue had no activity for 30 days, mark with Stale label.

@geomagilles
Copy link
Contributor Author

@codelipenghui: @avirlrma proposed to help

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
lifecycle/stale type/bug The PR fixed a bug or issue reported a bug
Projects
None yet
Development

No branches or pull requests

3 participants