apache / apache/rocketmq

rocketmq proxy里面findOneBroker为什么传clusterName

Open
#10,556 6 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
22.6k
Forks
12k
Avg merge
3d 1h
Merged PRs (30d)
27

Description

### Before Creating the Bug Report

- [x] I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq/discussions).

- [x] I have searched the [GitHub Issues](https://github.com/apache/rocketmq/issues) and [GitHub Discussions](https://github.com/apache/rocketmq/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

ubantu 20.04 Runtime platform environment: DOCKER

### RocketMQ version

5.3.1

### JDK Version

1.8

### Describe the Bug

@Override
protected SubscriptionGroupConfig getDirectly(String consumerGroup) throws Exception {
ProxyConfig config = ConfigurationManager.getProxyConfig();
String clusterName = config.getRocketMQClusterName();
Optional brokerDataOptional = findOneBroker(clusterName);
if (brokerDataOptional.isPresent()) {
String brokerAddress = brokerDataOptional.get().selectBrokerAddr();
return mqClientAPIFactory.getClient().getSubscriptionGroupConfig(brokerAddress, consumerGroup, DEFAULT_TIMEOUT);
}
return EMPTY_SUBSCRIPTION_GROUP_CONFIG;
}

### Steps to Reproduce

启动后proxy会报no topic route from namesrv

### What Did You Expect to See?

解决这个bug,发布新版本

### What Did You See Instead?

很紧急

### Additional Context

_No response_

Contributor guide

Open the contributing guide

Research direction

Start by tracing the proxy's getDirectly method, especially ProxyConfig.getRocketMQClusterName(), findOneBroker(clusterName), and the subsequent getSubscriptionGroupConfig call. Reproduce the issue with RocketMQ 5.3.1 on the stated Docker environment and verify the proxy no longer reports "no topic route from namesrv".

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
backend, distributed-systems
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Quiet
Clarity
Needs clarification
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.