Skip to content

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

Open
Open
producer.sendAsync is interrupted by client.close()#11780
Labels
lifecycle/staletype/bugThe PR fixed a bug or issue reported a bug

Description

@geomagilles
geomagilles
opened on 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

Activity

  1. geomagilles
    added
    type/bugThe PR fixed a bug or issue reported a bug
    on Aug 25, 2021

  2. avirlrma commented on Aug 31, 2021

    @avirlrma
    avirlrma
    on Aug 31, 2021

    Hi folks,

    Can I take this up?

  3. codelipenghui commented on Mar 4, 2022

    @codelipenghui
    codelipenghui
    on Mar 4, 2022
    Contributor

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

  4. codelipenghui
    added
    lifecycle/stale
    on Mar 4, 2022

  5. geomagilles commented on Mar 4, 2022

    @geomagilles
    geomagilles
    on Mar 4, 2022
    ContributorAuthor

    @codelipenghui: @avirlrma proposed to help

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    lifecycle/staletype/bugThe PR fixed a bug or issue reported a bug

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions