- 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.
* Remove all SI test-binder based components from core spring-cloud-stream-module
* Create a new module - spring-cloud-stream-test-binder that contains the test-binder
and all it's related components
* Migrate tests from core module that use the test-binder into a separate module
called spring-cloud-stream-integration-tests
* Remove the test-jar dependency using the classifier approach
* Update Spring Cloud Stream BOM with the new test-binder dependency
* Update Schema-Registry tests that use the old approach (using the test-jar with the classifier)
with the new test-binder dependency
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2565
- Cleanup in schema-registry samples (final variable).
- Add instructions in tools/kafka/docker-compose to run
a quick test using Kafka console scripts.
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
Remove `@RunWith(SpringRunner.class)` from sample code in Spring Integration Test Binder section:
1. It is a JUnit4 annotation
2. `@SpringBootTest` composes the JUnit5 counterpart (`@ExtendWith({SpringExtension.class})`)
Resolves#2537
