apache/pulsar

Broken subsequence of delayed messages

Open

#14 721 ouverte le 16 mars 2022

Voir sur GitHub
 (13 commentaires) (0 réactions) (1 assigné)Java (3 485 forks)batch import
help wantedtype/bug

Métriques du dépôt

Stars
 (13 697 stars)
Métriques de merge PR
 (Merge moyen 3j 10h) (146 PRs mergées en 30 j)

Description

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

Guide contributeur

Direction de recherche
Étudiez le mécanisme de livraison différée des messages dans Pulsar, en vous concentrant sur l'implémentation de InMemoryDelayedDeliveryTracker ou de DelayedDeliveryTracker. Le bogue est probablement lié à l'ordre des messages ayant le même horodatage de livraison. Examinez le code gérant la file d'attente prioritaire et l'avancement du curseur. Vérifiez les commentaires de l'issue pour toute information de diagnostic ou l'avancement de l'assigné. Fichiers suggérés : InMemoryDelayedDeliveryTracker.java, PersistentDispatcherMultipleConsumers.java.
Stack technique
java
Domaine
backend
Type d'issue
Bug
DifficultéDifficulté estimée pour un nouveau contributeur, de 1 pour un très petit changement à 5 pour un travail expert.
3
Temps estiméFourchette de temps approximative pour investiguer, implémenter, tester et préparer une pull request.
Une demi journée
Statut d'activitéDisponibilité apparente de l'issue : fraîche, active, ancienne, bloquée ou en attente d'un mainteneur.
Active
ClartéClarté avec laquelle l'issue explique le changement attendu, les critères d'acceptation et la prochaine étape.
Plutôt claire
Prérequis
JavaMessaging systems
Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.
60