Stream Processing with Spring Cloud Stream and Apache Kafka Streams. Part 2 - Programming Model Continued
On the heels of the previous blog in which we introduced the basic functional programming model for writing streaming applications with Spring Cloud Stream and Kafka Streams, in this part, we are going to further explore that programming model.
Let’s look at a few scenarios.
Scenario 1: Single input and output binding
If your application consumes data from a single input binding and produces data into an output binding, you can use Java’s Function interface to do that. Keep in mind that binding in this sense is not necessarily mapped to a single input Kafka topic, because topics could be…