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
These releases can be downloaded from Maven Central, JCenter, and our release repository:
If you don’t use Kinesis Binder. Or via Binder dependency:
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.
PutRecordsRequest(batch) support for
KplMessageHandlercollecting async results for
UserRecordsin that batch using Project Reactor
KinesisShardEndedEventis now emitted from the
KinesisMessageDrivenChannelAdapterwhen the next shard request returns
nullwith the meaning that shard is closed and no records can be added to that any more.
spring-cloud-stream-binder-kinesisis based on the recently released Spring Cloud Stream version
3.0and provides a new
KinesisBinderHealthIndicatorto check that all the streams involved in binding configurations are available.
ConsumerEndpointCustomizercan now be specified in the application context as bean and they are going to be injected into the
KinesisMessageChannelBinderfor an appropriate endpoints customization. This can be useful, for example, in cases when some endpoint properties are not covered by the configuration options.
Many thanks to everyone from the Community for all the feedback and contribution to these projects.
Any feedback is welcome via all the available communication channels!
Spring Integration for AWS resources:
Spring Cloud Stream Binder for AWS Kinesis resources: