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