ZIO-based AWS Kinesis client for Scala
Dependency upgrades and minor changes.
Breaking change: with the support for stream ARNs (#965), many streamName
parameters are renamed to streamIdentifier
. An implicit conversion from string to stream name or ARN is automatically in scope.
Dependency updates
Besides several enhancements and upgrades, some new options are available for the Producer
.
For applications that are not so sensitive to latency, batching can now be configured with a fixed interval, resulting in reduced CPU usage. Throttling and shard prediction can be disabled as well to reduce CPU usage. Several parameters to ProducerSettings
have changed to support these new options (see also #914 and #923):
aggregate
(default: false) has been replaced with Producer.Aggregation.Disabled
or Producer.Aggregation.ByPredictedShard(aggregationDuration)
shardPredictionParallelism
is replaced with Producer.ShardPrediction.Enabled(parallelism)
or Producer.ShardPrediction.Disabled
throttling
with values Producer.Throttling.Enabled(allowedErrorRate = 0.05)
(default) or Producer.Throttling.Disabled
.batchDuration
(default: None)Thanks to @mschuwalow for contributing to this release!
Re-release of v0.21.3 after fixing publishing config
Republish of v0.21.3 (ZIO 1 compatible version)
Dependency upgrades. Please note that there are some compatibility issues with ZIO 2.0.3, we're still investigating.
Producer.sinkChunked
and introduce sink
@svroonland (#791)