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

貢獻者指南