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