Releases
v0.8.0
Compare
Sorry, something went wrong.
No results found
0.8.0 (2021-01-14)
Features
Add ComputeHeadCursor RPC for Pub/Sub Lite. (#429 ) (34d8d02 )
Add non google default creds provider to subscribers in Spark Connector (#440 ) (2099751 )
Adds examples and fixes bugs in spark connector (#456 ) (d1c2a24 )
BlockingPullSubscriber in Spark Continuous Processing (#408 ) (36684c4 )
Changed assert to Preconditions check (#457 ) (f6f1bc4 )
Compute head offset for Spark connector micro batch mode. (#439 ) (f484754 )
fix bug where blockingpullsubscriber doesn't refill flowcontrol quota. (#449 ) (109bd83 )
Major classes for Spark continuous streaming (#396 ) (0c0d928 )
Multiple fixes to make continuous mode work (#432 ) (9df4ccf )
Separates Offsets from different context (Spark vs PSL) (#404 ) (b745f58 )
Spark connector readme (#441 ) (2ab6e3e )
Spark micro batch processing (#426 ) (86aecc9 )
Update spark connector pom.xml (#445 ) (624b123 )
Use the partition watching publisher in the cps client (#409 ) (b85ceb4 )
Bug Fixes
adding a method to the internal wire publisher that will attempt to cancel all outstanding publishes (#434 ) (7b9776e )
Attempt to start the publisher and publish in the ITVPC test (#420 ) (8ebc9f1 )
Extract the rpc exception from IllegalStateExceptins in publish/subscribe (#430 ) (ff05b1a )
Remove per-message byte limit in client (#435 ) (f7f36eb )
Dependencies
update dependency com.google.cloud:google-cloud-pubsub to v1.110.1 (#416 ) (92b4076 )
update dependency com.google.cloud:google-cloud-pubsub to v1.110.3 (#442 ) (cf78009 )
update dependency com.google.cloud:google-cloud-pubsub-bom to v1.110.1 (#417 ) (c90e506 )
update dependency com.google.cloud:google-cloud-pubsub-bom to v1.110.3 (#443 ) (594f79c )
update dependency com.google.cloud:google-cloud-shared-dependencies to v0.16.1 (19cae17 )
update dependency com.google.cloud:google-cloud-shared-dependencies to v0.17.0 (#428 ) (e56d2c2 )
update dependency com.google.cloud:google-cloud-shared-dependencies to v0.17.1 (#452 ) (ecdaef2 )
update dependency joda-time:joda-time to v2.10.9 (#436 ) (a5a305b )
update dependency org.slf4j:slf4j-api to v1.7.30 (#401 ) (2d9803b )
update jackson dependencies to v2.12.1 (#447 ) (d62cd7f )
Documentation
You can’t perform that action at this time.