I have a very basic spring-boot (3.3.2) + spring-cloud-stream based app which consumes messages from kinesis stream and prints the payload on console.
The application has a java.util.function.Consumer bean defined to consume the message from kinesis stream.