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

Support rich initialization modes of RocketMQSource

Open deemogsw opened this issue 2 years ago • 2 comments

perfect new features for new Source interface and sql connector. detail in #59

deemogsw avatar Oct 10 '22 06:10 deemogsw

bugs about RockerMQSource in current master branch:

  • [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 Oct 24 '22 09:10 deemogsw

I can help review pull requests.

lizhimins avatar Oct 28 '22 06:10 lizhimins