Spring Cloud Stream Kafka provides a binder specially designed for Kafka Streams binding. With this binder, the application can leverage the Kafka Streams API. To enable such a feature for your application, include the following dependency to your project:
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-stream-binder-kstream</artifactId></dependency>
The Kafka Streams API provides high-level stream DSL. It may be accessed by declaring the @StreamListener method that takes the KStream interface as a parameter. KStream provides some useful methods for stream manipulation, well-known from other streaming APIs such as map, flatMap, join, or filter. There are also some other methods ...
