Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Bug] CONSUMER_SEND_MSG_BACK request may be sent to ns #8963

Closed
3 tasks done
yx9o opened this issue Nov 20, 2024 · 0 comments · Fixed by #8964
Closed
3 tasks done

[Bug] CONSUMER_SEND_MSG_BACK request may be sent to ns #8963

yx9o opened this issue Nov 20, 2024 · 0 comments · Fixed by #8964

Comments

@yx9o
Copy link
Contributor

yx9o commented Nov 20, 2024

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

all

JDK Version

jdk1.8

Describe the Bug

In some scenarios, for example,

  • In master-slave mode, after the master fails, the slave node will consume data. If consumption fails, it will be sent back to the master broker. At this time, there is no master in the routing information, and the result is null. The request will be sent to ns.
  • In master-slave mode, when the master fails and recovers, the producer gets the routing information before the consumer. At this time, the producer sends data to the master, and the consumer consumes data on the slave node. If consumption fails, it will be sent back to the master broker. At this time, there is no master in the routing information, and the result is null. The request will be sent to ns.
image image

Steps to Reproduce

In master-slave mode, simulated consumption fails and returns ConsumeConcurrentlyStatus.RECONSUME_LATER
At this time, if you stop the master node, you will find that there is a request to send network ns.

What Did You Expect to See?

CONSUMER_SEND_MSG_BACK requests are only sent to brokers.

What Did You See Instead?

CONSUMER_SEND_MSG_BACK request is sent to ns.

Additional Context

No response

yx9o added a commit to yx9o/rocketmq that referenced this issue Nov 20, 2024
yuz10 pushed a commit that referenced this issue Nov 27, 2024
* [ISSUE #8963] Fix code36 request sent to ns

* Update DefaultMQPullConsumerImpl.java
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging a pull request may close this issue.

1 participant