diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java index 3364df48f89..4000ba1ef5d 100644 --- a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java +++ b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java @@ -276,8 +276,8 @@ public void assign(Collection messageQueues) { } @Override - public void setSubExpressionForAssign(final String topic, final String subExpresion) { - defaultLitePullConsumerImpl.setSubExpressionForAssign(withNamespace(topic), subExpresion); + public void setSubExpressionForAssign(final String topic, final String subExpression) { + defaultLitePullConsumerImpl.setSubExpressionForAssign(withNamespace(topic), subExpression); } @Override diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.java index 6c6a5970a60..ce2686393ab 100644 --- a/client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.java +++ b/client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.java @@ -223,7 +223,7 @@ public interface LitePullConsumer { * Manually commit consume offset saved by the system. * * @param messageQueues Message queues that need to submit consumer offset - * @param persist hether to persist to the broker + * @param persist whether to persist to the broker */ void commit(final Set messageQueues, boolean persist);