From 9cf519e1beaa6f22c50164f294faa6ca907c5714 Mon Sep 17 00:00:00 2001 From: hanmz Date: Wed, 24 Apr 2024 16:13:45 +0800 Subject: [PATCH] Fix some typos in DefaultLitePullConsumer and LitePullConsumer --- .../rocketmq/client/consumer/DefaultLitePullConsumer.java | 4 ++-- .../org/apache/rocketmq/client/consumer/LitePullConsumer.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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);