aloyszhang commented on code in PR #8941:
URL: https://github.com/apache/inlong/pull/8941#discussion_r1379893186
##########
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarUtils.java:
##########
@@ -273,7 +273,7 @@ public static void createPartitionedTopic(RestTemplate
restTemplate, PulsarClust
* @return pulsar internal stat info of partitioned topic
* @throws Exception any exception if occurred
*/
- public static JsonObject getPulsarStatsPartitionedTopics(RestTemplate
restTemplate,
+ public static JsonObject getStatsPartitionedTopics(RestTemplate
restTemplate,
Review Comment:
First of all, `partitioned-stats` and `partitioned-statsInternal` are two
different REST APIs for the pulsar.
The method name `getStatsPartitionedTopics` is not match with the URL
`clusterInfo.getAdminUrl() + QUERY_PERSISTENT_PATH + "/" + topicPath +
"/partitioned-internalStats"`
--
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]
