diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java index 0876a94e4c5..1c3f3da4d6e 100644 --- a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java +++ b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java @@ -35,6 +35,7 @@ import org.apache.rocketmq.remoting.exception.RemotingException; /** + * @deprecated * Default pulling consumer. * This class will be removed in 2022, and a better implementation {@link DefaultLitePullConsumer} is recommend to use * in the scenario of actively pulling messages.