apache/pulsar

PoolMessage and DLQ can not work together

Open

#13,269 opened on 2021年12月13日

GitHub で見る
 (6 comments) (0 reactions) (1 assignee)Java (3,485 forks)batch import
Stalehelp wantedlifecycle/staletype/bug

Repository metrics

Stars
 (13,697 stars)
PR merge metrics
 (平均マージ 3d 10h) (30d で 146 merged PRs)

説明

Describe the bug PoolMessage and DLQ can not work together

To Reproduce Steps to reproduce the behavior:

  1. Enable poolMessages and DLQ in consumer side
  2. Call consumer.negativeAcknowledge(message) and then call message.release()
  3. The message did not resend to DLQ topic.

Expected behavior The message should be sent to DLQ topic.

Additional context The negative ack msgs will be sent to DLQ topic in a scheduler triggerRedelivery, when we enable poolMessages, message.release() will clear MessageImpl immediately, this will cause processPossibleToDLQ() fail to get message id and resend to DLQ.

コントリビューターガイド