Google Git
Sign in
apache/flink-connector-pulsar/HEAD
  1. 08c8e2e [FLINK-38545] Update to Flink 1.20.3 and Pulsar 3.0.5 by Ferenc Csaky · 4 months ago main
  2. f3e9959 [hotfix] Apply spotless formatting by Ferenc Csaky · 5 months ago
  3. 0d05eb1 [hotfix] Standardize CI and update it to Flink 1.20 by Ferenc Csaky · 5 months ago
  4. eb67b4c [FLINK-35468][docs] Simplify `isEnableAutoAcknowledgeMessage` config comment by zhou zhuohan · 5 months ago
  5. d506716 [hotfix][docs] Explicitly set connector compatibility as string to prevent version comparison mismatch by Hong Liang Teoh · 5 months ago
  6. 3b4b184 [FLINK-35477] Make initial cursor position configurable by xu.guo · 11 months ago
  7. 0f7b744 [FLINK-37299] Stateless startup cannot continue consuming from current consumer group location by yebai1105 · 5 months ago
  8. 34f217b [FLINK-36180] Fix batch message data loss (#95) by wenbingshen · 1 year, 5 months ago
  9. 787f5e4 [hotfix] Refactor callers that use deprecated get/setXXX of Configuration by Rui Fan · 1 year, 6 months ago
  10. b37a8b3 [FLINK-35182] Bump org.apache.commons:commons-compress to 1.26.1 (#90) by gongzhongqiang · 1 year, 10 months ago
  11. 2629d0b [FLINK-34961] Use dedicated CI name for Pulsar connector to differentiate it in infra-reports by Sergey Nuyanzin · 1 year, 11 months ago
  12. 9f4b902 [FLINK-33884] Update Pulsar dependency to 3.0.2 in Pulsar Connector (#72) by David Christle · 1 year, 11 months ago
  13. 7a5eef2 [FLINK-34629][Stream] Fix non-partition topic subscribe lost. (#85) by David Christle · 1 year, 11 months ago
  14. 7340f71 [FLINK-34962] Use client.getPartitionsForTopic instead of lookup.getPartitionedTopicMetadata (#86) by Baodi Shi · 1 year, 11 months ago
  15. 5889eb2 [hotfix] Update copyright year to 2024 by Hang Ruan · 2 years, 1 month ago
  16. 6b5c662 [hotfix] Set copyright year to 2024 (#81) by gongzhongqiang · 2 years, 2 months ago
  17. 5b70da8 [FLINK-33970] Add necessary checks for connector document (#78) by gongzhongqiang · 2 years, 2 months ago
  18. f03bc56 [FLINK-33964][pulsar][docs] Remove dead link (#77) by gongzhongqiang · 2 years, 2 months ago
  19. 2be651a [FLINK-33964][pulsar][docs] Drop admin docs reference by tison · 2 years, 2 months ago
  20. aa80b9e [FLINK-33815] Follow up to fix YAML syntax by tison · 2 years, 3 months ago
  21. 8bfbe33 [FLINK-33815][Connector / Pulsar] Add tests against jdk17 for pulsar connector by Sergey Nuyanzin · 2 years, 3 months ago
  22. 707e494 [FLINK-33400] Be Compatible with Flink 1.18 (#69) by tison · 2 years, 3 months ago
  23. 74a4696 Bump org.apache.commons:commons-compress from 1.22 to 1.24.0 (#65) by dependabot[bot] · 2 years, 3 months ago
  24. 29f1e92 [hotfix][build] Bump version to 4.2-SNAPSHOT (#67) by Leonard Xu · 2 years, 3 months ago
  25. d958d15 Update version to 4.1-SNAPSHOT by tison · 2 years, 3 months ago
  26. a4e82fd [hotfix] Prepare for 4.1.0 release by tison · 2 years, 3 months ago
  27. bbc7c1e [FLINK-30400][build] Stop bundling flink-connector-base (#61) by Hang Ruan · 2 years, 3 months ago
  28. bec5feb [FLINK-26203] Add docs for the table connector (#63) by tison · 2 years, 4 months ago
  29. a026020 [hotfix] Extend CI timeout interval by tison · 2 years, 5 months ago
  30. f251640 [hotfix] Update idea vcs.xml file by tison · 2 years, 5 months ago
  31. 78d00ea [FLINK-32938] Replace pulsar admin calls (#59) by Neng Lu · 2 years, 6 months ago
  32. 63e62c6 [hotfix] Update NOTICE files to reflect year 2023 (#60) by Hang Ruan · 2 years, 6 months ago
  33. c71fc86 [FLINK-26203] Basic table factory for Pulsar connector (#56) by tison · 2 years, 6 months ago
  34. 3b6c3af [FLINK-24302] Extend offheap memory for JDK11 test coverage (#55) by tison · 2 years, 8 months ago
  35. 279a678 [FLINK-32612] Upgrade Pulsar version to 3.0.0 (#54) by tison · 2 years, 8 months ago
  36. f463d3f [FLINK-31923] Run daily builds against multiple branches and Flink versions by Martijn Visser · 2 years, 9 months ago
  37. 7ff8d70 [FLINK-32024][docs] Short code related to externalized connector retrieve version from its own data yaml by Weijie Guo · 2 years, 10 months ago
  38. 67e85eb [hotfix] Python connector download link should refer to the url defined in externalized repository by Weijie Guo · 2 years, 10 months ago
  39. 9e8ef1d [hotfix] Workaround new violations message (#45) by tison · 2 years, 10 months ago
  40. bbb636a [FLINK-31748] Dummy implementation to fix compilation failure (#43) by tison · 2 years, 11 months ago
  41. e0de157 [hotfix] Improve CI trigger and cancel strategy (#42) by tison · 3 years ago
  42. 042454d [hotfix] Allow manual run of daily build by Martijn Visser · 3 years ago
  43. aecd8cf [hotfix] Test CI runs against Flink 1.17.0 and Daily builds against 1.17-SNAPSHOT and 1.18-SNAPSHOT by Martijn Visser · 3 years ago
  44. 4387701 [FLINK-31725] Synchronize dependency versions between Flink and flink-connector-pulsar. This closes #41 by MartijnVisser · 3 years ago
  45. 104bdc3 [FLINK-31676][Connector/Pulsar] Replace Shaded Guava from Flink with Shaded Guava from Pulsar by Martijn Visser · 3 years ago
  46. 33526f5 [FLINK-31618][docs] Fix the wrong links in producer option docs by Yuxin Tan · 3 years ago
  47. eaea5d6 [hotfix][Build] Adjust running time of nightly CI from weekly to daily. (#34) by Weijie Guo · 3 years, 1 month ago
  48. 47b588f [FLINK-31100][Stream] Support the short topic pattern subscriber on default tenant and namespace. by Yufan Sheng · 3 years, 1 month ago
  49. 2c43292 [FLINK-31101][Test] Drop the use of JUnit 5 assertions and mockito. by Yufan Sheng · 3 years, 1 month ago
  50. 64bc829 [FLINK-28959][Stream] Add warn hit for using regex subscription in PulsarSourceBuilder. by Yufan Sheng · 3 years, 1 month ago
  51. 59d1363 [FLINK-28959][Stream] Fix the generation of TopicPartition. by Yufan Sheng · 3 years, 1 month ago
  52. 53d1468 [FLINK-28959][Stream] Fix the wrong use of Guava's Preconditions. by Yufan Sheng · 3 years, 1 month ago
  53. 8db5350 [FLINK-28959][Stream] Use binary protocol for topic filtering. by Yufan Sheng · 3 years, 1 month ago
  54. 471d24c [FLINK-28959][Stream] Add retry and rate limit for admin request. by Yufan Sheng · 3 years, 1 month ago
  55. 8b58e7f [FLINK-30606][Connector/Pulsar] Bump the pulsar-client-all to latest 2.11.0. (#25) by Yufan Sheng · 3 years, 1 month ago
  56. a39770d [FLINK-31067][Build] Add pull request template for flink-connector-pulsar. by Weijie Guo · 3 years, 1 month ago
  57. e1cd220 [hotfix] Fix incorrect java doc in PulsarSink and PulsarSinkBuilder. by Weijie Guo · 3 years, 1 month ago
  58. fb98096 [FLINK-31048][Connector/Pulsar] Fix incorrect java doc in PulsarSource and PulsarSourceBuilder. by Weijie Guo · 3 years, 1 month ago
  59. 2278653 [FLINK-30109][Connector/Pulsar] Drop the use of sneaky exception. (#24) by Yufan Sheng · 3 years, 1 month ago
  60. 5f0bb2d [FLINK-30489][Connector/Pulsar] Shade all the dependencies in flink-sql-connector-pulsar. (#26) by Yufan Sheng · 3 years, 1 month ago
  61. a963c46 [FLINK-30654][Connector/Pulsar] Add an option to force consumption from StartCursor every time the application starts. (#23) by Yufan Sheng · 3 years, 1 month ago
  62. cb082e9 [FLINK-30622][Connector/Pulsar] Support consuming messages with schema auto-detection from Pulsar. (#19) by Yufan Sheng · 3 years, 1 month ago
  63. 6d5629f [FLINK-30976][docs] Replaces old Flink shortcode 'artifact' with the connector-repo-specific shortcode 'connector-artifact' (#22) by Matthias Pohl · 3 years, 1 month ago
  64. 8496061 [FLINK-30963][ci] Streamline binary URL configuration by Chesnay Schepler · 3 years, 1 month ago
  65. 39c1a15 [FLINK-28351][Connector/Pulsar] Add dynamic sink topic support for Pulsar connector. (#14) by Yufan Sheng · 3 years, 1 month ago
  66. dfc2c54 [FLINK-30689][Connector/Pulsar] Support sending message byte with extra schema check. (#20) by Yufan Sheng · 3 years, 1 month ago
  67. 5ce2373 [FLINK-30681][Connector/Pulsar] Add a warning hint on the delivery guarantee document. (#18) by Yufan Sheng · 3 years, 2 months ago
  68. 6991f38 [FLINK-28870][Connector/Pulsar] Improve the Pulsar source performance when meeting small data rates. (#15) by Yufan Sheng · 3 years, 2 months ago
  69. 5173e70 [FLINK-28082][Connector/Pulsar] Add end-to-end encryption support for Pulsar connector. (#13) by Yufan Sheng · 3 years, 2 months ago
  70. 99f4ce4 [FLINK-25686][Connector/Pulsar] Support schema evolution for Pulsar source and sink. (#12) by Yufan Sheng · 3 years, 2 months ago
  71. 6e5ed0c [FLINK-30552][Connector/Pulsar] Drop next message id calculation, use resetCursor api to exclude the given message. (#11) by Yufan Sheng · 3 years, 2 months ago
  72. d8f6056 [FLINK-30413][Connector/Pulsar] Drop subscription support, remove unorder consuming, change related tests. (#10) by Yufan Sheng · 3 years, 2 months ago
  73. bc5ae99 [FLINK-30430][Connector/Pulsar] Remove all the useless dependencies, drop mock runtime. (#9) by Yufan Sheng · 3 years, 2 months ago
  74. 6fe0a44 [FLINK-30175] Bump snakeyaml from 1.31 to 1.33 by dependabot[bot] · 3 years, 3 months ago
  75. 06ef03b [FLINK-30427][Connector/Pulsar] Correct scope for bouncycastle dependencies to make sure they are bundled. Pulsar requires these, per https://pulsar.apache.org/docs/2.10.x/security-bouncy-castle/ by Martijn Visser · 3 years, 3 months ago
  76. d82256b [FLINK-30426][Archunit] Set archRule.failOnEmptyShould = false to return old behavior. This closes #7 by Sergey Nuyanzin · 3 years, 3 months ago
  77. 34dd86f [hotfix] Fix workflow reference by Martijn Visser · 3 years, 3 months ago
  78. 6205470 [hotfix] Manually copy over generated layout shortcodes by Martijn Visser · 3 years, 3 months ago
  79. f547f7b [hotfix] Amend NOTICE by Chesnay Schepler · 3 years, 3 months ago
  80. 11a0274 [hotfix] Fix workflow reference by Chesnay Schepler · 3 years, 3 months ago
  81. b40f1b5 [hotfix] Add missing LICENSE and NOTICE file by Martijn Visser · 3 years, 3 months ago
  82. 56b1e5e [hotfix][ci] Reuse workflow by Chesnay Schepler · 3 years, 3 months ago
  83. b1e4d51 [hotfix][ci] Fix workflow by Chesnay Schepler · 3 years, 3 months ago
  84. 15e1372 [hotfix][ci] Remove repo name from workflow files by Chesnay Schepler · 3 years, 3 months ago
  85. 0e05cb5 [hotfix][ci] Only run weekly in Apache repo by Chesnay Schepler · 3 years, 3 months ago
  86. c5c9227 [FLINK-30353][ci] Limit concurrency by Chesnay Schepler · 3 years, 3 months ago
  87. ded956e [hotfix][architecture] Add ProductionCodeArchitectureTest by Martijn Visser · 3 years, 3 months ago
  88. e35b5e7 [hotfix] Set version to 4.0-SNAPSHOT by Martijn Visser · 3 years, 3 months ago
  89. 7360e65 [hotfix] Increase timeout for compile and test runs by Martijn Visser · 3 years, 3 months ago
  90. 858931e [FLINK-30336][Connector/Pulsar] Sync missing Pulsar e2e tests to external repo by Martijn Visser · 3 years, 3 months ago
  91. bf7af29 [FLINK-26027][Connector/Pulsar] Expose Pulsar producer metrics and add FLIP-33 sink metrics. (#21249) by Yufan Sheng · 3 years, 4 months ago
  92. 9004447 [FLINK-29709][Connector/Pulsar] Bump the Pulsar to latest 2.10.2 (#21204) by Yufan Sheng · 3 years, 4 months ago
  93. 1b1aa9a [FLINK-29495][Connector/Pulsar] Refactor Pulsar tests from JUnit4 annotation to JUnit5 annotation for disabling tests on Java 11 by Martijn Visser · 3 years, 5 months ago
  94. 79e968d [FLINK-29532][Connector/Pulsar] Update Pulsar dependency to 2.10.1. This closes #20980 by MartijnVisser · 3 years, 5 months ago
  95. 0ce6280 [FLINK-26182][Connector/pulsar] Create e2e tests for the Pulsar source and sink based on the connector testing framework. by Yufan Sheng · 3 years, 5 months ago
  96. 712f647 [FLINK-26182][Connector/pulsar] Extract common logic from Pulsar source testing tools. by Yufan Sheng · 3 years, 5 months ago
  97. f333cf2 [FLINK-29285][tests] Move TestUtils#getResource by Chesnay Schepler · 3 years, 6 months ago
  98. f4a7fa0 Update version to 1.17-SNAPSHOT by huangxingbo · 3 years, 6 months ago
  99. 9714ebb [FLINK-28409][tests] Move FlinkContainerTestEnvironment and dependendencies into flink-connector-test-utils by Alexander Fedulov · 3 years, 8 months ago
  100. 65ae7f7 [FLINK-27199][Connector/Pulsar] Bump the pulsar-client-all to latest 2.10.0. by Yufan Sheng · 3 years, 8 months ago