apache/pulsar

Broken subsequence of delayed messages

Open

#14.721 aperta il 16 mar 2022

Vedi su GitHub
 (13 commenti) (0 reazioni) (1 assegnatario)Java (3485 fork)batch import
help wantedtype/bug

Metriche repository

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

Descrizione

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

Guida contributor

Direzione di ricerca
Indaga sul meccanismo di consegna ritardata dei messaggi in Pulsar, concentrandoti sull'implementazione di InMemoryDelayedDeliveryTracker o DelayedDeliveryTracker. Il bug potrebbe riguardare l'ordinamento dei messaggi con lo stesso timestamp di consegna. Esamina il codice che gestisce la coda prioritaria e l'avanzamento del cursore. Controlla i commenti dell'issue per eventuali informazioni diagnostiche o i progressi dell'assegnatario. File suggeriti: InMemoryDelayedDeliveryTracker.java, PersistentDispatcherMultipleConsumers.java.
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.
Mezza giornata
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Attiva
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Abbastanza chiara
Prerequisiti
JavaMessaging systems
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
60