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