Google Git
Sign in
apache / rocketmq-flink / HEAD
  1. b9efd1e Implement new flink-connector-rocketmq base on FLIP-27/FLIP-191 (#94) by lizhimins · 9 weeks ago main
  2. 45590d1 Merge pull request #86 from ni-ze/main by Ni Ze · 5 months ago main-latest
  3. cc9d48b polish(serial) add the generic type, Map<String, String>, into SimpleKeyValueDeserializationSchema by 维章 · 5 months ago
  4. 422909f [ISSUE #76] Fix bug when the job restore from ck (#77) by 高思伟 · 10 months ago
  5. 9d0e78d bump rocketmq schema registry version (#71) by 李晓双 Li Xiao Shuang · 11 months ago
  6. 3af5c0d [ISSUE #67] Bugfix for consume blocking by 高思伟 · 11 months ago
  7. ebbba23 [ISSUE #35] Use `LitePullConsumer` model instead of default pull consumer(#46) by yiduwangkai · 11 months ago
  8. 90b00be update README.md (#66) by 高思伟 · 12 months ago
  9. 875100c Update .asf.yaml by yukon · 12 months ago
  10. e8d5350 [ISSUE #59] Support rich initialization modes of RocketMQ source (#62) by 高思伟 · 12 months ago
  11. 460694b [ISSUE #57] Fix some problems with the catalog (#61) by 李晓双 Li Xiao Shuang · 1 year ago
  12. afba019 Revert "Fix some problems with the catalog (#58)" (#60) by Nicholas Jiang · 1 year ago
  13. 6909cbc Fix some problems with the catalog (#58) by 李晓双 Li Xiao Shuang · 1 year ago
  14. 0e27ff8 [ISSUE #12] Support scan startup mode (#54) by Yubin Li · 1 year, 1 month ago
  15. b7c00f3 [issues-32] Implement of Apache RocketMQ Flink Catalog. (#49) by 李晓双 Li Xiao Shuang · 1 year, 1 month ago
  16. 1764058 Update .travis.yml by dinglei · 1 year, 1 month ago
  17. 7291859 Update .asf.yaml by dinglei · 1 year, 1 month ago
  18. 8fd83d7 support 'startMessageOffset' for RocketMQSourceFunction (#52) by Nicholas Jiang · 1 year, 1 month ago
  19. 4721e3e support 'startMessageOffset' for RocketMQSourceFunction (#51) by Nicholas Jiang · 1 year, 1 month ago
  20. a5d0f97 support 'startMessageOffset' for RocketMQSourceFunction (#50) by Nicholas Jiang · 1 year, 1 month ago
  21. 017db20 [issues-44] support access control (#47) by lizhimins · 1 year, 2 months ago
  22. cc923f1 [Hotfix] RocketMQSourceFunction retains offsets after multiple retry times of topic route change (#43) by Nicholas Jiang · 1 year, 2 months ago
  23. 87fb9c2 Merge pull request #45 from lizhimins/support-acl by Nicholas Jiang · 1 year, 2 months ago
  24. 034c4f2 [issues-44] support access control by 斜阳 · 1 year, 2 months ago
  25. 7095755 Update README label format. by dinglei · 1 year, 2 months ago
  26. 638b7fa Merge pull request #42 from SteNicholas/hotfix-persist-offset by Nicholas Jiang · 1 year, 2 months ago
  27. 6656964 [Hotfix] RocketMQSourceFunction persists offset in notifyCheckpointComplete by SteNicholas · 1 year, 2 months ago
  28. 0106c3d Merge pull request #39 from gj-zhang/message-queue-selector by Nicholas Jiang · 1 year, 3 months ago
  29. 65e3402 add licence by rancho_zhanggj · 1 year, 3 months ago
  30. 749ca65 spotless apply by rancho_zhanggj · 1 year, 3 months ago
  31. 37358b4 support message queue selector. by rancho_zhanggj · 1 year, 3 months ago
  32. a21cc04 Merge pull request #38 from hunter-cloud09/1.0.0 by dinglei · 1 year, 3 months ago
  33. e92d048 [issues-18] update README.md by hunter-cloud09 · 1 year, 3 months ago
  34. 6bd8ede [issues-18] update README.md by liusq · 1 year, 3 months ago
  35. 2d5c3ec Persist consumer offset to broker when new msg found from queues. (#37) by dinglei · 1 year, 3 months ago
  36. 9d131e7 Merge pull request #28 from GOODBOY008/issues-21 by Nicholas Jiang · 1 year, 4 months ago
  37. 931b2cd [issues-21] support SQL92 filter mod. by gongzhongqiang · 1 year, 4 months ago
  38. 64c11ff Merge pull request #31 from GOODBOY008/bump_flink_version by Nicholas Jiang · 1 year, 4 months ago
  39. 619e889 Bump flink version to 1.15.0. by gongzhongqiang · 1 year, 4 months ago
  40. 95de766 [issues-21] support SQL92 filter mod. by gongzhongqiang · 1 year, 7 months ago
  41. ef6b813 [#26] Bump flink version to 1.14.3 by Nicholas Jiang · 1 year, 6 months ago
  42. d530ebe [issues-26] Bump flink version to 1.14.3. by gongzhongqiang · 1 year, 7 months ago
  43. e303ea9 [upgrade flink version] upgrade flink version to 1.14 (#23) by yiduwangkai · 1 year, 11 months ago
  44. b8c8a16 hudi RocketMQDynamicTableSink had format violations (#14) by yiduwangkai · 1 year, 11 months ago
  45. 8dd74ef Update README.md (#10) by Utopia · 2 years ago
  46. 84a552d Merge pull request #8 from liyubin117/convert-return-name by SteNicholas · 2 years ago
  47. 7c2fc19 convertToRowTypeInfo() return field types and name by Yubin Li · 2 years ago
  48. 5240969 ISSUE-4:fix SimpleKeyValueDeserializationSchema and SimpleKeyValueDeserializationSchema class field Accessibility. (#5) by gongzhongqiang · 2 years ago
  49. 2f498ed Update NOTICE by von gosling · 2 years, 1 month ago
  50. 0c44c1b Update NOTICE by von gosling · 2 years, 1 month ago
  51. f98a692 Remove useless config by vongosling · 2 years, 1 month ago
  52. f2372ce Update README.md by von gosling · 2 years, 1 month ago
  53. 1951644 Ignore dependency-reduced-pom.xml by von gosling · 2 years, 1 month ago
  54. abeae5e Update pom.xml by von gosling · 2 years, 1 month ago
  55. 413ff29 Update .travis.yml by von gosling · 2 years, 1 month ago
  56. 31fbe5c Update README.md by von gosling · 2 years, 1 month ago
  57. d521fc0 Update .travis.yml by von gosling · 2 years, 1 month ago
  58. 32b51b1 Update pom.xml by von gosling · 2 years, 1 month ago
  59. 79f6dc2 Let rat pass by vongosling · 2 years, 1 month ago
  60. da37aee Bugfix for default branch logic by vongosling · 2 years, 1 month ago
  61. 989679b format(code): fix many coding vilations by vongosling · 2 years, 1 month ago
  62. b329dbe Update .travis.yml by von gosling · 2 years, 1 month ago
  63. a5d979d Update README.md by von gosling · 2 years, 1 month ago
  64. d930448 Create .travis.yml by Heng Du · 2 years, 1 month ago
  65. f67e776 Create .asf.yaml by Heng Du · 2 years, 1 month ago
  66. aafb8e4 introduce RocketMQ SQL connector document (#793) by SteNicholas · 2 years, 1 month ago
  67. aae7134 RocketMQSource improves the message consume of RocketMQPartitionSplitReader (#791) by SteNicholas · 2 years, 1 month ago
  68. bf27790 [#786] RocketMQSourceFunction supports the close of ExecutorService and ScheduledExecutorService (#790) by SteNicholas · 2 years, 1 month ago
  69. bbd7c6d [#780] Support the RocketMQ TableSink based on the legacy Sink implementation (#781) by SteNicholas · 2 years, 1 month ago
  70. 4edc4da [#715] Support the RocketMQ TableSource based on the legacy Source implementation (#779) by SteNicholas · 2 years, 1 month ago
  71. 465c60a Build pass jdk9+ by vongosling · 2 years, 2 months ago
  72. 340ea48 [#715] Support the RocketMQ TableSource based on the new Source interface (#716) by SteNicholas · 2 years, 4 months ago
  73. f882acf [#705] Support the implementation of new Source interface (#706) by SteNicholas · 2 years, 6 months ago
  74. da92a64 [rocketmq-connector-flink] rebalance cause offset rollback to long time ago (#672) by JerryTaoTao · 2 years, 8 months ago
  75. fe936a5 [ISSUE #656] Update flink connector rocketmq, support flink metrics (#657) by lizhimins · 2 years, 10 months ago
  76. 635a72d [ISSUE #337] throw exception when send message to broker fail (#339) by zhengwen zhu · 3 years, 2 months ago
  77. a78d575 feat(rocketmq-flink)upgrade rocketmq client to 4.7.1 (#589) by Heng Du · 3 years, 3 months ago
  78. 92d4cc3 Fix Checkstyle issue (#532) (#533) by Nishadi Kirielle · 3 years, 6 months ago
  79. a04b0bf No need to call this function twice (#329) by 胖梁 · 4 years, 1 month ago
  80. 7059330 [ISSUE #385]Add acl feature support for rocketmq-flink (#384) by Heng Du · 4 years, 1 month ago
  81. 0698d86 Producer failed to shutdown when exception happened (#388) by shangan · 4 years, 1 month ago
  82. c6cb79d Merge pull request #229 from Jennifer-sarah/master by Xin Wang · 4 years, 3 months ago
  83. 0be1ed7 code format by zhu zhengwen · 4 years, 3 months ago
  84. fc79313 create client instance for each sink/source by zhu zhengwen · 4 years, 3 months ago
  85. 42a5d6c Verify flink prs by vongosling · 4 years, 4 months ago
  86. c9564d6 fix(module): fix load wrong offset from savepoint (#288) by MeYJ · 4 years, 4 months ago
  87. 58d07fb Fix getting wrong offset bug when the source restart (#190) by tangyoupeng · 4 years, 4 months ago
  88. b5c05e0 flink-rocketmq-sink , producer send message set delay level (optional… (#237) by xlzl · 4 years, 4 months ago
  89. 8531921 fix concurrent checkpoint bug by Jennifer-sarah · 4 years, 6 months ago
  90. 8089fb1 clean up some dirty code by Jennifer-sarah · 4 years, 7 months ago
  91. f74cc27 Optimizing update offset code logic by Jennifer-sarah · 4 years, 7 months ago
  92. 65e3029 update consumer offset after checkpoint completed by Jennifer-sarah · 4 years, 7 months ago
  93. 452b57f Add batch size param for flink sink (#198) by shangan · 4 years, 8 months ago
  94. 1c36e71 Remove python and go repositories by vongosling · 4 years, 9 months ago
  95. 624994d Fix NPE when getting offset(#153) by SuXingLee · 4 years, 10 months ago
  96. 11e2e6d ISSUE-61: Added javadocs for RocketMQ-Flink (#63) by Xin Wang · 5 years ago
  97. 12f0d0c [ROCKETMQ-82] RocketMQ-Flink Integration (#45) by Xin Wang · 6 years ago
  98. c05c018 Create directory for beam,flink,spark,storm,mysql,redis,mongodb by dongeforever · 6 years ago