apache/pulsar

Broken subsequence of delayed messages

Open

#14.721 geöffnet am 16. März 2022

Auf GitHub ansehen
 (13 Kommentare) (0 Reaktionen) (1 zugewiesene Person)Java (3.485 Forks)batch import
help wantedtype/bug

Repository-Metriken

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

Beschreibung

Describe the bug Delayed messages to shared topic breaks subsequence of messages and delivered earlier than expected.

To Reproduce Steps to reproduce the behavior:

  1. Setup local standalone pulsar
  2. Send messages every 20ms with the same deliverAt timestamp 10000ms and with payload of millisecond when sending was started.
  3. Log received messages payload.

I start receiving all messages after 9 seconds and it I have in log:

9001ms
1ms
21ms
41ms
61ms
81ms
...
8981ms
(here should be 9001ms)
9021ms
9041ms
...

Expected behavior Two expectations:

  1. Most important I expect first message to be received is message '1ms' and message '9001ms' after '8981ms'.
  2. I expect start receiving messages after 10 seconds

Issue is reproduced in 2.8.0 and 2.9.1

Contributor Guide

Research-Richtung
Untersuchen Sie den Mechanismus für die verzögerte Nachrichtenlieferung in Pulsar, mit Fokus auf die Implementierung von InMemoryDelayedDeliveryTracker oder DelayedDeliveryTracker. Der Fehler betrifft wahrscheinlich die Reihenfolge von Nachrichten mit demselben Lieferzeitstempel. Sehen Sie sich den Code an, der die Prioritätswarteschlange und den Cursor Vorschub behandelt. Überprüfen Sie die Kommentare im Issue auf diagnostische Informationen oder den Fortschritt des Zuständigen. Vorgeschlagene Dateien: InMemoryDelayedDeliveryTracker.java, PersistentDispatcherMultipleConsumers.java.
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.
Halber Tag
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.
Meist klar
Voraussetzungen
JavaMessaging systems
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
60