You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by GitBox <gi...@apache.org> on 2023/01/09 16:52:24 UTC
[GitHub] [rocketmq] HScarb opened a new issue, #5844: Failed to examine pop consumer group status/progress/connection, no topic route for retry topic
HScarb opened a new issue, #5844:
URL: https://github.com/apache/rocketmq/issues/5844
1. Please describe the issue you observed:
- What did you do (The steps to reproduce)?
1. Use pop consume API `MQClientAPIImpl.popMessageAsync` to pop a message from topic
2. Use MQAdmin consumerProgress/consumerStatus/consumerConnection command to examine pop consumer stats
- What is expected to see?
Consumer stats returns properly
- What did you see instead?
```log
MQClientException: CODE: 17 DESC: No topic route info in name server for the topic: %RETRY%cid-test
```
2. Please tell us about your environment:
Rocketmq 5.0.1-snapshot, latest develop branch
3. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):
`consumerProgress/consumerStatus/consumerConnection`
These three commands both build and examine route info for normal retry topic of pop consumer, that's where the exception raises, as pop consumer won't create a normal retry topic.
---
I didn't come up with a perfect solution for this issue, but I have several approches
1. Build a dummy retry topic when a consumer call pop API for the first time.
2. Catch the exception raised by `examineTopicRouteInfo`, so the MQAdmin commands would execute without exception
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] RongtongJin commented on issue #5844: Failed to examine pop consumer group status/progress/connection, no topic route for retry topic
Posted by GitBox <gi...@apache.org>.
RongtongJin commented on issue #5844:
URL: https://github.com/apache/rocketmq/issues/5844#issuecomment-1376675574
> 1. MQClientAPIImpl.popMessageAsync
It seems that MQClientAPIImpl.popMessageAsync was directly called, resulting in no heartbeat being sent and no retry topic being created.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] ShadowySpirits commented on issue #5844: Failed to examine pop consumer group status/progress/connection, no topic route for retry topic
Posted by GitBox <gi...@apache.org>.
ShadowySpirits commented on issue #5844:
URL: https://github.com/apache/rocketmq/issues/5844#issuecomment-1376653849
The broker creates the retry topic automatically when a consumer first sends a heartbeat.
see ClientManageProcessor#heartBeat:
https://github.com/apache/rocketmq/blob/a68078fef8315a0deeae32af42a029ccd2fa76a4/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java#L112-L117
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] ni-ze commented on issue #5844: Failed to examine pop consumer group status/progress/connection, no topic route for retry topic
Posted by GitBox <gi...@apache.org>.
ni-ze commented on issue #5844:
URL: https://github.com/apache/rocketmq/issues/5844#issuecomment-1376636692
IMO, I think neither are good solution. Use retry topic just want to find the broker address. Maybe we can solution like this:
```java
Collection<BrokerData> values = this.examineBrokerClusterInfo().getBrokerAddrTable().values();
for (BrokerData value : values) {
String addr = value.selectBrokerAddr();
if (StringUtils.isNotBlank(addr)) {
ConsumerConnection result = this.mqClientInstance.getMQClientAPIImpl().getConsumerConnectionList(addr, consumerGroup, timeoutMillis);
if (result != null) {
return result;
}
}
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] xdkxlk commented on issue #5844: Failed to examine pop consumer group status/progress/connection, no topic route for retry topic
Posted by GitBox <gi...@apache.org>.
xdkxlk commented on issue #5844:
URL: https://github.com/apache/rocketmq/issues/5844#issuecomment-1378346366
The command like `consumerProgress` can set the topic name to avoid this problem by `-t`, in the short term.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Failed to examine pop consumer group status/progress/connection, no topic route for retry topic [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #5844:
URL: https://github.com/apache/rocketmq/issues/5844#issuecomment-1888166692
This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Failed to examine pop consumer group status/progress/connection, no topic route for retry topic [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #5844:
URL: https://github.com/apache/rocketmq/issues/5844#issuecomment-1891122286
This issue was closed because it has been inactive for 3 days since being marked as stale.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] Failed to examine pop consumer group status/progress/connection, no topic route for retry topic [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] closed issue #5844: Failed to examine pop consumer group status/progress/connection, no topic route for retry topic
URL: https://github.com/apache/rocketmq/issues/5844
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org