Issue
I see that following annotations are depreciated for Spring Cloud Stream
@Input
@Output
@EnableBinding
@StreamListener
Please provide examples and links to documentation as how to do it in functional way.
Solution
This github repository contains a lot of examples..
https://github.com/spring-cloud/stream-applications
The official documentation explains in details how to move from imperative to functional style in spring cloud stream applications with kafka streams but is the same without it.
Please also check this post..
https://spring.io/blog/2019/10/14/spring-cloud-stream-demystified-and-simplified
There is an example of imperative code (https://docs.spring.io/spring-cloud-stream-binder-kafka/docs/3.1.0/reference/html/spring-cloud-stream-binder-kafka.html#_imperative_programming_model) and how it should be developed with functional style.
Answered By - 50qbits