Releases
v0.1.0
0.1.0 (2023-03-14)
Features
Add a limit to the number of bytes that can be outstanding to a publisher (#54 ) (8bc5058 )
Add a publisher cache for the pubsub lite sink (#18 ) (52ab0ba )
Add a publisher which can wait for outstanding messages (#19 ) (69fb64a )
Add a serializing publisher (#20 ) (65824e0 )
Add build scripts for native image testing in Java 17 (#1440 ) (#139 ) (6f3bd36 )
Add SplitDiscovery for use in split enumerator (#14 ) (b68d2b4 )
Add the checkpoint and serializer for the split enumerator (#12 ) (e4649d5 )
Add the DeserializingSplitReader (#11 ) (8b63ec4 )
Add the pubsub lite source and settings (#17 ) (5e1bb41 )
Add the pubsub lite source reader (#13 ) (2c407e9 )
Add the pubsublite sink (#21 ) (186c93b )
Add the pubsublite split enumerator (#16 ) (8a79086 )
Add the stop condition to allow users to stop based on offsets (#59 ) (4d3f41d )
Add the Uniform partition assigner (#15 ) (5f7abc2 )
Create the completable pull subscriber: a version of blocking pull subscriber which can finish (#7 ) (f5ae84f )
Create the MessageSplitReader (#10 ) (24b8e7e )
Initial code generation (f2ab73d )
Initial commit, create an implementation of SourceSplit for a subscription partition (#5 ) (879fc3f )
Integration test for the psl sink and source (#22 ) (1c654d1 )
Restructure flink connector for new internal APIs and reduce API surface (#173 ) (2d287cb )
Upgrade Pub/Sub Lite version (#187 ) (76794d4 )
Bug Fixes
Change commit logic to use streams instead of single RPCs (#177 ) (a1d06f0 )
Change to use the sinkv2 interfaces (#186 ) (e142808 )
Enable longpaths support for windows test (#1485 ) (#144 ) (3bcbc6b )
Fix errors caused by client library upgrade (#50 ) (5e5caf3 )
Fix Java 17 build. No wildcard import. (#86 ) (9102c5f )
java: Add -ntp flag to native image testing command (#1299 ) (#89 ) (46ecef7 )
java: Java 17 dependency arguments (#1266 ) (#77 ) (5dd4901 )
java: Run Maven in plain console-friendly mode (#1301 ) (#97 ) (c4d856b )
Move internal packages to "internal" use a property for flink and pubsublite versions (#45 ) (0a7f0a9 )
test: Fix flake in PubsubLiteSourceReaderTest (#44 ) (09871f3 )
Upgrade flink connector to version 1.15.0, equivalent to dataproc 2.1 (#176 ) (b80a462 )
Use a cursor client so we can close the client (#55 ) (7de246d )
Various fixes for flink (#183 ) (ed2207f )
Documentation
Dependencies
java: Update actions/github-script action to v5 (#1339 ) (#107 ) (7e8b628 )
Update actions/github-script action to v6 (#118 ) (316d979 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v0.18.0 (#34 ) (0e74b49 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.11.2 (#189 ) (093511b )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.3.0 (#74 ) (a91ca46 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.4.1 (#83 ) (9824ff0 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.4.10 (#113 ) (b6ef366 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.4.11 (#117 ) (07715c2 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.4.12 (#129 ) (ccdf443 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.4.3 (#91 ) (8038470 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.4.5 (#92 ) (3a5967e )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.4.6 (#93 ) (5c4801e )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.4.7 (#95 ) (dbffea2 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.4.8 (#99 ) (1b1050f )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.5.0 (#131 ) (be0b592 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.5.1 (#132 ) (39828fc )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.5.2 (#133 ) (a35345f )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.5.3 (#134 ) (232a473 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.5.4 (#137 ) (05ab761 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.5.5 (#138 ) (52936b5 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.6.0 (#140 ) (6174a17 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.6.1 (#143 ) (a8c3e95 )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.6.3 (#147 ) (b05b54a )
Update dependency com.google.cloud:google-cloud-pubsublite-parent to v1.9.4 (#151 ) (fef6285 )
Update dependency kr.motd.maven:os-maven-plugin to v1.7.1 (#166 ) (0ca1b3d )
Update dependency org.slf4j:slf4j-api to v1.7.32 (#29 ) (6c3f6e6 )
Update dependency org.slf4j:slf4j-api to v1.7.34 (#105 ) (3c955b9 )
Update dependency org.slf4j:slf4j-api to v1.7.35 (#110 ) (0c456a1 )
Update dependency org.slf4j:slf4j-api to v1.7.36 (#116 ) (cc09d80 )
Update dependency org.slf4j:slf4j-api to v2 (#148 ) (0cfef6a )
Update dependency org.slf4j:slf4j-api to v2.0.6 (#150 ) (9eb5ebc )
Update flink.version to v1.13.1 (#46 ) (56ce037 )
Update flink.version to v1.13.2 (#51 ) (754e2c1 )
Update pubsublite.version to v0.18.0 (#47 ) (e4a88f3 )
You can’t perform that action at this time.