Adjust after merge, use ledgerID for get message by id

streamnative · Jan 10, 2025 · 4c58077 · 4c58077
1 parent c933c86
commit 4c58077
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/ctl/subscription/get_message_by_id.go b/pkg/ctl/subscription/get_message_by_id.go
@@ -77,12 +77,12 @@ func doGetMessageByID(vc *cmdutils.VerbCmd, ledgerID int64, entryID int64) error
 	}
 
 	client := cmdutils.NewPulsarClient()
-	messages, err := client.Subscriptions().GetMessagesByID(*topic, legerID, entryID)
+	messages, err := client.Subscriptions().GetMessagesByID(*topic, ledgerID, entryID)
 	if err != nil {
 		return err
 	}
 	if len(messages) == 0 {
-		return fmt.Errorf("no message found with the given legerID and entryID")
+		return fmt.Errorf("no message found with the given ledgerID and entryID")
 	}
 	message := messages[0]
 	propertiesJSON, err := json.Marshal(message.GetProperties())