Skip to content

[Bug] Ack failure on message listener in multi topics consumer #446

Closed
@nkurihar

Description

@nkurihar

Search before asking

  • I searched in the issues and found nothing similar.

Version

main branch
commit id: 8b2753a

Minimal reproduce step

  1. publish a certain amount of messages to the target topic
  2. start a "multi topic" (e.g. partitioned, list, regex) consumer with message listener
  3. ack failure with AlreadyClosed occurs

example:

// publishing messages continuously
$ pulsar-perf produce -s 1 persistent://my-tenant/my-ns/my-partitioned-topic

// restart consumer several times
$ ./SampleConsumerListener 
^C
$ ./SampleConsumerListener
^C
.
.
.
2024-10-02 17:48:13.309 INFO  [0x16afff000] MultiTopicsConsumerImpl:308 | Successfully Subscribed to a single partition of topic in TopicsConsumer. Partitions need to create : 3
2024-10-02 17:48:13.309 INFO  [0x16afff000] HandlerBase:138 | Finished connecting to broker after 218 ms
2024-10-02 17:48:13.309 ERROR [0x16b117000] SampleConsumerListener:34 | Failed to ack: AlreadyClosed, Message(prod=xxx, seq=70, publish_time=1727858342279, payload_size=1, msg_id=(62407117,85,0,0), props={})
2024-10-02 17:48:13.309 ERROR [0x16b117000] SampleConsumerListener:34 | Failed to ack: AlreadyClosed, Message(prod=xxx, seq=71, publish_time=1727858342439, payload_size=1, msg_id=(62407117,86,0,0), props={})
2024-10-02 17:48:13.309 ERROR [0x16b117000] SampleConsumerListener:34 | Failed to ack: AlreadyClosed, Message(prod=xxx, seq=72, publish_time=1727858342599, payload_size=1, msg_id=(62407117,87,0,0), props={})

What did you expect to see?

All messages should be acked successfully

What did you see instead?

Failed to ack some messages

Anything else?

No response

Are you willing to submit a PR?

  • I'm willing to submit a PR!

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions