rocketmq-flink
rocketmq-flink copied to clipboard
Use litePullConsumer model instead of default pull consumer.
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.
refer to https://github.com/apache/rocketmq/blob/develop/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java
i will solve it
@yiduwangkai, thanks. I have assigned this ticket to you.