Spring Integration AWS 2.3 GA and Spring Cloud Stream Kinesis Binder 2.0 GA Available
Dear Spring Community,
Today it’s my pleasure to announce General Availability of Spring Integration for Amazon Web Services extension version 2.3.0
and Spring Cloud Stream Binder for AWS Kinesis version 2.0.0
.
These releases can be downloaded from Maven Central, JCenter, and our release repository:
compile "org.springframework.integration:spring-integration-aws:2.3.0.RELEASE"
If you don’t use Kinesis Binder. Or via Binder dependency:
compile "org.springframework.cloud:spring-cloud-stream-binder-kinesis:2.0.0.RELEASE"
Release Highlights
-
The main theme of both these releases is about an integration testing using a Local Stack framework which helped us to spot several bugs and race conditions in both libraries.
-
The
spring-integration-aws
provides aPutRecordsRequest
(batch) support forKplMessageHandler
collecting async results forUserRecords
in that batch using Project ReactorMono.fromFuture()
functionality. -
A
KinesisShardEndedEvent
is now emitted from theKinesisMessageDrivenChannelAdapter
when the next shard request returnsnull
with the meaning that shard is closed and no records can be added to that any more. -
The
…spring-cloud-stream-binder-kinesis
is based on the recently released Spring Cloud Stream version3.0
and provides a newKinesisBinderHealthIndicator
to check that all the streams involved in binding configurations are available.