apache/pulsar

Broken subsequence of delayed messages

Open

#14,721 创建于 2022年3月16日

在 GitHub 查看
 (13 评论) (0 反应) (1 负责人)Java (3,485 fork)batch import
help wantedtype/bug

仓库指标

Star
 (13,697 star)
PR 合并指标
 (平均合并 3天 10小时) (30 天内合并 146 个 PR)

描述

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

贡献者指南