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