[Bug] When write some timer message, if the topic has been deleted, it is not processed at that time. Excess data is written - Githubissues

apache / rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.

https://rocketmq.apache.org/

Apache License 2.0

21.11k stars 11.63k forks source link

[Bug] When write some timer message, if the topic has been deleted, it is not processed at that time. Excess data is written #8537

Open leizhiyuan opened 1 month ago

leizhiyuan commented 1 month ago

Before Creating the Bug Report

[X] I found a bug, not just asking a question, which should be created in GitHub Discussions.
[X] I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.
[X] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.

Runtime platform environment

mac

RocketMQ version

develop

JDK Version

jdk8

Describe the Bug

When delaying the scrolling of the message, if the topic has been deleted, it is not processed at that time. Excess data is written

Steps to Reproduce

write some timer messages
delete the biz topic
when timer message expired, will also write the consumequeue of biz topic

What Did You Expect to See?

3 will return error

What Did You See Instead?

will also write the consumequeue of biz topic

Additional Context

No response

leizhiyuan commented 1 month ago

maybe we can check topicConfigManager contains the real topic in org.apache.rocketmq.broker.util.HookUtils#checkBeforePutMessage