DZone

Overview

In this article, we’ll introduce the main concepts and constructs of Spring Cloud Stream with some simple test-examples based on EmbeddedKafkaRule using MessageCollector

Getting Started

Dependencies & Configuration

To get started, we’ll need to add the Spring Cloud Starter Stream with the Kafka broker Gradle dependency to our build.gradle:

Source: DZone