dovics opened a new issue, #1167:
URL: https://github.com/apache/rocketmq-client-go/issues/1167
**FEATURE REQUEST**
1. Please describe the feature you are requesting.
there is no way To obtain the MaxOffset of a Topic, is it possible to also
provide methods such as `examineTopicStats` in the `MQAdminExt` interface in
the Go SDK.
https://github.com/apache/rocketmq/blob/280804c5592341f92a43b6d72ec6e94db77b74ac/tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java#L128
```
TopicStatsTable examineTopicStats(
final String topic) throws RemotingException, MQClientException,
InterruptedException,
MQBrokerException;
TopicStatsTable examineTopicStats(String brokerAddr,
final String topic) throws RemotingException, MQClientException,
InterruptedException,
MQBrokerException;
```
2. Provide any additional detail on your proposed use case for this feature.
I am developing a KEDA Scaler based on RocketMQ, which will dynamically
adjust the number of Pods based on the difference between the ConsumerGroup
Offset and the Topic MaxOffset. I can get the ConsumerGroup Offset through the
`PullConsumer.CurrentOffset` method, But I also need a method to get MaxOffset.
2. Indicate the importance of this issue to you (blocker, must-have,
should-have, nice-to-have). Are you currently using any workarounds to address
this issue?
blocker
4. If there are some sub-tasks using -[] for each subtask and create a
corresponding issue to map to the sub task:
None
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
