apache/pulsar

Broken subsequence of delayed messages

オープン

#14,721 opened on 2022/03/16

 (13 件のコメント) (0 件のリアクション) (1 人の担当者)Java (3,485 件のフォーク)batch import
help wantedtype/bug

Repository metrics

Stars
 (13,697 個のスター)
PR merge metrics
 (平均マージ 3d 10h) (30d で 146 merged PRs)

説明

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

コントリビューターガイド