apache/pulsar

PoolMessage and DLQ can not work together

Open

#13.269 aperta il 13 dic 2021

Vedi su GitHub
 (6 commenti) (0 reazioni) (1 assegnatario)Java (3485 fork)batch import
Stalehelp wantedlifecycle/staletype/bug

Metriche repository

Star
 (13.697 star)
Metriche merge PR
 (Merge medio 3g 10h) (146 PR mergiate in 30 g)

Descrizione

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.

Guida contributor

Direzione di ricerca
Indaga l'interazione tra PoolMessage e DLQ nel programmatore di re recapito del consumatore (triggerRedelivery). Concentrati su come message.release() cancella MessageImpl e come processPossibleToDLQ() recupera l'ID del messaggio. Considera l'aggiunta di un ritardo o la memorizzazione dell'ID del messaggio prima del rilascio, o la ristrutturazione della logica di negative acknowledgement.
Tech stack
java
Dominio
backend
Tipo issue
Bug
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
1-2 giorni
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Attiva
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Chiara
Prerequisiti
JavaApache Pulsar
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
55