This is an automated email from the ASF dual-hosted git repository. xiangying pushed a commit to branch branch-4.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit a6c28ae9d97905048ba51c6dadc8831294294e3e Author: Xiangying Meng <[email protected]> AuthorDate: Tue Jun 24 16:02:52 2025 +0800 [fix][cli] Print result of GetMessageIdByIndex command (#24446) Co-authored-by: xiangying <[email protected]> (cherry picked from commit 5841238d49695e29f557e22ce964d5b7470a354a) --- .../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 5ee04d8817f..bb8eb6393ce 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 @@ -5120,7 +5120,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)); } } }
