apache/pulsar

PoolMessage and DLQ can not work together

Open

#13.269 geöffnet am 13. Dez. 2021

Auf GitHub ansehen
 (6 Kommentare) (0 Reaktionen) (1 zugewiesene Person)Java (3.485 Forks)batch import
Stalehelp wantedlifecycle/staletype/bug

Repository-Metriken

Stars
 (13.697 Stars)
PR-Merge-Metriken
 (Durchschn. Merge 3T 10h) (146 gemergte PRs in 30 T)

Beschreibung

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.

Contributor Guide

Research-Richtung
Untersuchen Sie die Interaktion zwischen PoolMessage und DLQ im Wiederversandplaner des Consumers (triggerRedelivery). Konzentrieren Sie sich darauf, wie message.release() MessageImpl löscht und wie processPossibleToDLQ() die Nachrichten ID abruft. Erwägen Sie, vor der Freigabe eine Verzögerung hinzuzufügen oder die Nachrichten ID zu speichern, oder die Logik der negativen Bestätigung umzustrukturieren.
Tech Stack
java
Domain
backend
Issue Type
Fehler
SchwierigkeitGeschätzte Implementierungsschwierigkeit für neue Contributors, von 1 für sehr kleine Änderungen bis 5 für Expertenarbeit.
3
Geschätzte ZeitEin grober Zeitrahmen, um zu recherchieren, zu implementieren, zu testen und einen Pull Request vorzubereiten.
1-2 Tage
AktivitätsstatusWie verfügbar das Issue gerade wirkt: frisch, aktiv, stale, blockiert oder wartet auf Maintainer-Input.
Aktiv
KlarheitWie klar das Issue die erwartete Änderung, Akzeptanzkriterien und den nächsten Schritt erklärt.
Klar
Voraussetzungen
JavaApache Pulsar
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
55