rocketmq-flink
rocketmq-flink copied to clipboard
[#35] Use `LitePullConsumer` model instead of default pull consumer
close #35
Use DefaultLitePullConsumer model instead of default pull consumer.
Tips Thank you very much for contributing to Apache rocketmq-flink. What is the purpose of the pull request *solve some code about using defaultPullConsumer api
Brief change log (for example:)
*Modify RocketMQConfig.java RocketMQSourceFunction.java RocketMQSourceEnumerator.java RocketMQPartitionSplitReader.java RocketMQSourceTest.java
there are some problems about this code, like home to Use defaultlitPullConsumer to get offset and perform offset self-management
Codecov Report
Merging #46 (3f5fbe4) into main (90b00be) will increase coverage by
0.11%. The diff coverage is5.15%.
@@ Coverage Diff @@
## main #46 +/- ##
============================================
+ Coverage 28.50% 28.62% +0.11%
Complexity 164 164
============================================
Files 62 62
Lines 2529 2536 +7
Branches 269 269
============================================
+ Hits 721 726 +5
- Misses 1741 1743 +2
Partials 67 67
| Impacted Files | Coverage Δ | |
|---|---|---|
| ...g/apache/rocketmq/flink/legacy/RocketMQConfig.java | 0.00% <ø> (ø) |
|
| .../rocketmq/flink/legacy/RocketMQSourceFunction.java | 9.80% <0.00%> (+0.24%) |
:arrow_up: |
| ...g/apache/rocketmq/flink/source/RocketMQSource.java | 0.00% <0.00%> (ø) |
|
| ...nk/source/enumerator/RocketMQSourceEnumerator.java | 0.00% <0.00%> (ø) |
|
| ...nk/source/reader/RocketMQPartitionSplitReader.java | 0.00% <0.00%> (ø) |
|
| .../apache/rocketmq/flink/common/RocketMQOptions.java | 98.41% <100.00%> (+0.05%) |
:arrow_up: |
| ...ource/table/RocketMQDynamicTableSourceFactory.java | 68.18% <100.00%> (+0.73%) |
:arrow_up: |
| ...mq/flink/source/table/RocketMQScanTableSource.java | 27.27% <100.00%> (+0.95%) |
:arrow_up: |
:mega: We’re building smart automated test selection to slash your CI/CD build times. Learn more
Thanks for @yiduwangkai updates. Could you please resolve the conflicts and squash the commits?
Thanks, @yiduwangkai for your contributions. I left some comments, but I'm not familiar with rocketmq-flink, so please @SteNicholas help have a look.
Since not all broker versions support lite pull, we need to clarify it in our doc.