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

[rocketmq-flink]pendingOffsetsToCommit in RocketMQSource is not used anywhere

Open bithw1 opened this issue 6 years ago • 0 comments

RocketMQSource defines a variable pendingOffsetsToCommit as

private LinkedMap pendingOffsetsToCommit;

But I didn't find real use of it, can it be removed?

bithw1 avatar Oct 08 '19 11:10 bithw1