Fs2 Google Pubsub Versions Save

Google Cloud Pub/Sub stream-based client built on top of cats-effect, fs2 and http4s.

v0.22.1

4 weeks ago

v0.22.0

1 year ago

What's Changed

New Contributors

Full Changelog: https://github.com/permutive-engineering/fs2-google-pubsub/compare/v0.21.0...v0.22.0

v0.21.0

1 year ago

v0.21.0

We have Scala 3 support! 🎉

What's Changed

Full Changelog: https://github.com/permutive-engineering/fs2-google-pubsub/compare/v0.20.0...v0.21.0

v0.18.1

2 years ago

Note this is the equivalent of v0.20.0, but still using CE2.

This release makes a change to the way we process messages from Pub/Sub which should considerably improve performance.

Changes from v0.18.0: #330 Emit larger chunks in HTTP and gRPC consumers (based on @istreeter's #329, thanks @bastewart)

Note this change as a few caveats, please let us know if you experience any issues with this:

  • In both consumer variants if any message in a chunk fails to decode the errorHandler is invoked before any successfully decoded messages in the chunk are emitted downstream; even if the message which failed to decode comes after the successful ones.
  • In the gRPC variant alone the stream may fail sooner if an internal failure occurs in the Java library. This should not matter at all.
  • The user-provided errorHandler callback will now get called for all messages in the chunk before the chunk gets emitted downstream

v0.20.0

2 years ago

This release makes a change to the way we process messages from Pub/Sub which should considerably improve performance.

Changes from v0.19.0: https://github.com/permutive/fs2-google-pubsub/pull/330 Emit larger chunks in HTTP and gRPC consumers (based on @istreeter's #329, thanks @bastewart)

Note this change as a few caveats, please let us know if you experience any issues with this:

  • In both consumer variants if any message in a chunk fails to decode the errorHandler is invoked before any successfully decoded messages in the chunk are emitted downstream; even if the message which failed to decode comes after the successful ones.
  • In the gRPC variant alone the stream may fail sooner if an internal failure occurs in the Java library. This should not matter at all.
  • The user-provided errorHandler callback will now get called for all messages in the chunk before the chunk gets emitted downstream

v0.19.0

2 years ago

This release updates to use cats-effect 3 which causes breaking changes to the API.

Changes from v0.18.0

Dependency updates:

Dependency Version
cats-effect 3.2.9
fs2 3.1.2
http4s 0.23.3
log4cats 2.1.1
google-cloud-pubsub 1.114.0*

*This has been downgraded from 1.114.3 after an incorrect git merge, sorry!

v0.18.0

2 years ago

Note some previous 0.18.0.-* pre-release versions used cats-effect 3, this release uses cats-effect 2.

This will be the final release on cats-effect which adds new features. Future releases on CE2 will be patch releases for security and the like.

Changes from v0.17.0

Features:

  • (#308) Expose message attributes in ConsumerRecord
  • (#282) Fail stream on internal Google PubSub library error (gRPC consumer variant)

Breaking changes:

Dependency updates:

Dependency Version
Scala 2.12 2.12.14
Scala 2.13 2.13.6
cats 2.6.1
cats-effect 2.5.3
fs2 2.5.9
http4s 0.21.28
java-jwt 3.18.2
jsoniter 2.10.2
google-cloud-pubsub 1.114.3

v0.18.0-M1

3 years ago

Milestone release to using cats-effect 3.0. Marked as milestone due to http4s being a milestone release itself.

v0.17.0

3 years ago

The main changes are:

Other:

v0.16.1

3 years ago

This release contains Scala and dependency version updates.

Dependency updates:

Dependency Version
cats 2.2.0
cats-effect 2.2.0
fs2 2.4.4
http4s 0.21.7
log4cats 1.1.1
jsoniter 2.6.0
google-cloud-pubsub 1.108.1