pulsar icon indicating copy to clipboard operation
pulsar copied to clipboard
verified publisher icon apache

[Java Client] Fix DLQ message can not send when enable poolMessages

Open wangjialing218 opened this issue 4 years ago • 2 comments

Motivation

Fixes #13269

Modifications

When message is put into possibleSendToDeadLetterTopicMessages, do not clear it in release() since it will be used when send to DLQ later. And clear the message when it is removed from possibleSendToDeadLetterTopicMessages

Verifying this change

This change is already covered by existing tests, such as PulsarSinkE2ETest.testPulsarSinkDLQ() just enable poolMessage for client.

Documentation

  • [x] no-need-doc

    Only bug fix

wangjialing218 avatar Dec 14 '21 06:12 wangjialing218

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

github-actions[bot] avatar Feb 26 '22 01:02 github-actions[bot]

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

github-actions[bot] avatar May 30 '22 02:05 github-actions[bot]