Spring Integration 3.0.1 doesnt support KCL2 with Enhanced Fanout
Closed this issue · 0 comments
In what version(s) of Spring Integration AWS are you seeing this issue?
3.0.0 and beyond
Describe the bug
The Multi stream implementation for KCLMessageDrivenChannelAdapter doesnt register the stream consumers in Enhanced fan out mode.
To Reproduce
Use KCL Message Driven Adapter with multiple streams. Provide multiple streams in the array.
Expected behavior
For each stream, Enhanced Fan out consumer should be registered in Kinesis with the same consumer group. The lease table should use the multi stream format.
The same has been reported on stackoverflow linked with spring cloud stream kinesis binder.
https://stackoverflow.com/questions/77158552/spring-cloud-stream-kinesis-binder-4-0-doesnt-support-multi-stream-with-kcl-2-e