search

apache / rocketmq-flink

RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
https://rocketmq.apache.org/
Apache License 2.0
139 stars 88 forks source link

Use litePullConsumer model instead of default pull consumer. #35

Closed ShannonDing closed 1 year ago

ShannonDing commented 1 year ago

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 commented 1 year ago

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

yiduwangkai commented 1 year ago

i will solve it

SteNicholas commented 1 year ago

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