rocketmq-flink icon indicating copy to clipboard operation
rocketmq-flink copied to clipboard

Use litePullConsumer model instead of default pull consumer.

Open ShannonDing opened this issue 3 years ago • 3 comments

See description in RocketMQ,

 /**
 * @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.
 */

the DefaultMQPullConsumer will be removed soon in the latest version. it is better to change the connect reader impl to DefaultLitePullConsumer API.

ShannonDing avatar Jul 11 '22 01:07 ShannonDing

refer to https://github.com/apache/rocketmq/blob/develop/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java

ShannonDing avatar Jul 11 '22 02:07 ShannonDing

i will solve it

galaxy077 avatar Jul 14 '22 15:07 galaxy077

@yiduwangkai, thanks. I have assigned this ticket to you.

SteNicholas avatar Jul 15 '22 00:07 SteNicholas