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