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

1.[fix lite pull consumer api] #74

Open yiduwangkai opened 1 year ago

yiduwangkai commented 1 year ago

[fix lite pull consumer api] Version below 4.6.0 does not support DefaultLitePullConsumer

SteNicholas commented 1 year ago

@yiduwangkai, could you please correct the title of the pull request and resolve the conflicts of RocketMQSourceFunction?