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

[ISSUE #63] Support rich initialization modes of RocketMQSource & Fix some bugs

Open deemogsw opened this issue 3 years ago • 5 comments

Support rich initialization modes of RocketMQSource Fix some bugs

deemogsw avatar Nov 03 '22 13:11 deemogsw

  • [x] [bug]PartitionDiscoveryIntervalMs can't set to negative
  • [x] [bug]Idle source task can't be released automatic
  • [x] [bug]Offset didn't commit to broker in RockerMQSource in phase of checkpoint
  • [x] [bug]Records can't arrive to sink() in UNBOUNDESS mode
  • [x] [features]Commit offset immediately when checkpoint is disable
  • [x] [features]Support rich initialization modes
  • [x] [features]Metrics with new source
  • [x] [features]Boost for flink-sql-connector

deemogsw avatar Nov 03 '22 13:11 deemogsw

As description in issue #69 ,branch of master has some bugs with pr #46 .So my branch still be dependent on common pull mode. I will complete the README.md with usage of sql-connector later. @lizhimins @SteNicholas Can you help me review the code?

deemogsw avatar Nov 03 '22 14:11 deemogsw

@deemogsw Thanks for your contributions! Can you rebase to last main branch.

GOODBOY008 avatar Nov 09 '22 01:11 GOODBOY008

@deemogsw Thanks for your contributions! Can you rebase to last main branch.

Main branch has bug in litepull consumer.I have mentioned in issue #69 .You can also have a try by running the latest cade

deemogsw avatar Nov 09 '22 09:11 deemogsw

@deemogsw, could you please resolve the conflicts firstly?

SteNicholas avatar Nov 14 '22 10:11 SteNicholas