descriptionRocketMQ 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.
ownerThe Apache Software Foundation
last changeTue, 30 Aug 2022 00:39:54 +0000 (08:39 +0800)
shortlog
2022-08-30  Yubin Li[ISSUE #12] Support scan startup mode (#54) main
2022-08-23  李晓双 Li Xiao... [issues-32] Implement of Apache RocketMQ Flink Catalog...
2022-08-23  dingleiUpdate .travis.yml
2022-08-23  dingleiUpdate .asf.yaml
2022-08-22  Nicholas Jiangsupport 'startMessageOffset' for RocketMQSourceFunction...
2022-08-22  Nicholas Jiangsupport 'startMessageOffset' for RocketMQSourceFunction...
2022-08-22  Nicholas Jiangsupport 'startMessageOffset' for RocketMQSourceFunction...
2022-07-26  lizhimins[issues-44] support access control (#47)
2022-07-26  Nicholas Jiang[Hotfix] RocketMQSourceFunction retains offsets after...
2022-07-26  Nicholas JiangMerge pull request #45 from lizhimins/support-acl
2022-07-24  斜阳[issues-44] support access control 45/head
2022-07-20  dingleiUpdate README label format.
2022-07-20  Nicholas JiangMerge pull request #42 from SteNicholas/hotfix-persist...
2022-07-20  SteNicholas[Hotfix] RocketMQSourceFunction persists offset in... 42/head
2022-07-15  Nicholas JiangMerge pull request #39 from gj-zhang/message-queue...
2022-07-13  rancho_zhanggjadd licence 39/head
...
heads
3 weeks ago main