Spring Cloud Stream Reference Guide
		Next

Spring Cloud Stream Reference Guide

Sabby Anandan, Marius Bogoevici, Eric Bottard, Mark Fisher, Ilayaperumal Gopinathan, Gunnar Hillert, Mark Pollack, Patrick Peralta, Glenn Renfro, Thomas Risberg, Dave Syer, David Turanski, Janne Valkealahti

1.0.0.RC1

Copies of this document may be made for your own use and for distribution to others, provided that you do not charge any fee for such copies and further provided that each copy contains this Copyright Notice, whether distributed in print or electronically.

Table of Contents

I. Reference Guide

II. Spring Cloud Stream Reference Manual

1. Introducing Spring Cloud Stream

2. Spring Cloud Stream Main Concepts

2.1. Application structure

2.1.1. Fat JAR

2.2. Persistent publish subscribe and consumer groups

2.2.1. Consumer Groups
2.2.2. Durability

2.3. Partitioning

3. Programming model

3.1. Declaring and binding channels

3.1.1. Triggering binding via @EnableBinding

3.1.2. @Input and @Output

Customizing channel names
Source, Sink, and Processor

3.1.3. Accessing bound channels

Injecting the bound interfaces
Injecting channels directly

3.1.4. Programming model

Native Spring Integration support
@StreamListener for automatic content type handling

3.2. Binder SPI

3.2.1. Producers and Consumers
3.2.2. Kafka Binder
3.2.3. RabbitMQ Binder

4. Configuration options

4.1. Spring Cloud Stream Properties

4.2. Binding properties

4.2.1. Properties for the use of Spring Cloud Stream
4.2.2. Consumer properties
4.2.3. Producer properties

5. Binder-specific configuration

5.1. Rabbit-specific settings

5.1.1. Rabbit MQ Binder properties
5.1.2. Rabbit MQ Consumer Properties
5.1.3. Rabbit Producer Properties

5.2. Kafka-specific settings

5.2.1. Kafka binder properties
5.2.2. Kafka Consumer Properties
5.2.3. Kafka Producer Properties

6. Binder detection

6.1. Classpath Detection
6.2. Multiple Binders on the Classpath
6.3. Connecting to Multiple Systems

7. Content Type and Transformation

7.1. Type converting message channels
7.2. @StreamListener and conversion

8. Inter-app Communication

8.1. Connecting multiple application instances

8.2. Instance Index and Instance Count

8.3. Partitioning

8.3.1. Configuring Output Bindings for Partitioning

Configuring Input Bindings for Partitioning

9. Health Indicator

10. Samples

11. Getting Started