Skip to content

[Bug] Start the consumer first, the producer sends a message to rocketmq and the consumer can't receive it #7195

@zooah212

Description

@zooah212

Before Creating the Bug Report

  • I found a bug, not just asking a question, which should be created in GitHub Discussions.

  • I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.

  • I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.

Runtime platform environment

Linux

RocketMQ version

5.1.3

JDK Version

1.8

Describe the Bug

New RocketMQ environment, start the consumer first, the producer sends a message to MQ and the consumer can't receive it. After a few seconds send another message to MQ and the consumer can receives the message. Message Model is Broadcasting, Consume_From_Where is CONSUME_FROM_LAST_OFFSET.
If the producer sends the message first and starts the consumer later, the message will not lost.

Steps to Reproduce

If the Message Model is Clustering, Consume_From_Where is CONSUME_FROM_LAST_OFFSET, the first message can not receive too, but in the dashboard page the message shows that it has been consumed.

What Did You Expect to See?

In the new RocketMQ environment, can receive the first message.

What Did You See Instead?

The first message is missing.

Additional Context

No response

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions