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 <55571188+liangyepianz...@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 <mengxiangy...@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)); } } }