You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zi...@apache.org on 2025/06/24 08:02:57 UTC
(pulsar) branch master updated: [fix][cli] Print result of GetMessageIdByIndex command (#24446)
This is an automated email from the ASF dual-hosted git repository.
zixuan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 5841238d496 [fix][cli] Print result of GetMessageIdByIndex command (#24446)
5841238d496 is described below
commit 5841238d49695e29f557e22ce964d5b7470a354a
Author: Xiangying Meng <55...@users.noreply.github.com>
AuthorDate: Tue Jun 24 16:02:52 2025 +0800
[fix][cli] Print result of GetMessageIdByIndex command (#24446)
Co-authored-by: xiangying <me...@xiaohongshu.com>
---
.../main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java | 2 +-
.../src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
index 42683d521d5..ac38bd67ee7 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java
@@ -5073,7 +5073,7 @@ public class PersistentTopics extends PersistentTopicsBase {
.thenAccept(asyncResponse::resume)
.exceptionally(ex -> {
if (!isRedirectException(ex)) {
- log.error("[{}] Failed to get message id by index for topic {}, partition id {}, index {}",
+ log.error("[{}] Failed to get message id by index for topic {}, index {}",
clientAppId(), topicName, index, ex);
}
resumeAsyncResponseExceptionally(asyncResponse, ex);
diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
index b8ed4c30d87..e123db66fa7 100644
--- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
+++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
@@ -3073,7 +3073,7 @@ public class CmdTopics extends CmdBase {
@Override
void run() throws Exception {
String topic = validateTopicName(topicName);
- getAdmin().topics().getMessageIdByIndex(topic, index);
+ System.out.println(getAdmin().topics().getMessageIdByIndex(topic, index));
}
}
}