diff --git a/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java b/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java index 019414b9e5c151d29fe6f093a8caf13a6e89efe8..63b2d14531d9dc11b811b113f361f24cb54a9331 100644 --- a/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java +++ b/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java @@ -82,7 +82,7 @@ public interface MQAdmin { long earliestMsgStoreTime(final MessageQueue mq) throws MQClientException; /** - * Query message according tto message id + * Query message according to message id * * @param offsetMsgId message id * @return message