- Kinesis binder depends on spring-cloud-aws library which only becomes available
after the spring-cloud (2022) release that includes Spring Cloud Stream release.
This creates a cycle and thus we cannot include Kinesis binder release as part
of the Spring Cloud Stream release train.
See this issue for more details: https://github.com/spring-cloud/spring-cloud-stream/issues/2572
- Subsequently, we will remove the source code for Kinesis binder from core SCSt repostiroy and move
it into it's own space (as it was before).
Fix ClassCastException when handling error while using batch mode that prevents the republish of the message into the DLQ. The issue happened whenever the republish to dlq was enabled or if republish was disabled and max attempts were > 1 while the batch mode was enabled, because the handler was not expecting the the sourceData for the ErrorMessage could be a list of amqp message.
Use a retry template for topic description method call through admin client
when provisioning consumer destinations. We are retrying because in the event
this operation gets failed, it is retried with the default retry settings in the provisioner.
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2520
Currently, in Kafka Streams binder-based apps, processor beans
need to be declared public. This is unnecessary and caused by
some restrictions in the binder. This PR fixes this restriction.
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2516
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2510
New feature on RabbitMQ (Super Stream with Single Active Consumer) enables
scaling out app instances when using this queue type/config.
`RabbitStreamMessageHandler` is now available in Spring Integration.
This commit establishes the concept of binder identity (binder instance identity) to be used in cases where unique-to-the-binder-instance naming is required.
For example such naming is required to fix GH-2507 where error channel names could colide if two binders use the same destination name.
Resolves#2512Resolves#2507
