apache/pulsar

Broken subsequence of delayed messages

Open

#14.721 aberto em 16 de mar. de 2022

Ver no GitHub
 (13 comments) (0 reactions) (1 assignee)Java (3.485 forks)batch import
help wantedtype/bug

Métricas do repositório

Stars
 (13.697 stars)
Métricas de merge de PR
 (Mesclagem média 3d 10h) (146 fundiu PRs em 30d)

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

Guia do colaborador

Direção de pesquisa
Investigue o mecanismo de entrega de mensagens atrasadas no Pulsar, focando na implementação do InMemoryDelayedDeliveryTracker ou do DelayedDeliveryTracker. O bug provavelmente está relacionado à ordenação de mensagens com o mesmo carimbo de data/hora de entrega. Examine o código que lida com a fila de prioridade e o avanço do cursor. Verifique os comentários da issue para quaisquer informações de diagnóstico ou o progresso do responsável. Arquivos sugeridos: InMemoryDelayedDeliveryTracker.java, PersistentDispatcherMultipleConsumers.java.
Pilha de tecnologia
java
Domain
backend
Tipo Issue
Bug
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
3
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
Meio dia
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
Ativo
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
Principalmente claro
Prerequisites
JavaMessaging systems
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
60