Spring Cloud Stream Reference Guide

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

1.0.0.BUILD-SNAPSHOT

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
1. Spring Cloud Stream Modules
1.1. Overview
II. Modules
2. Sources
2.1. File Source
2.1.1. Options
2.2. FTP Source
2.2.1. Options
2.3. Http Source
2.3.1. Options
2.4. JDBC Source
2.4.1. Options
2.5. JMS Source
2.5.1. Options
2.6. Load Generator Source
2.6.1. Options
2.7. RabbitMQ Source
2.7.1. Options
A Note About Retry
2.8. SFTP Source
2.8.1. Options
2.9. SYSLOG Source
2.9.1. Options
2.10. TCP
2.10.1. Options
2.10.2. Available Decoders
2.11. Time Source
2.11.1. Options
2.12. Trigger Source
2.12.1. Options
2.13. Twitter Stream Source
2.13.1. Options
3. Processors
3.1. Bridge Processor
3.2. Filter Processor
3.2.1. Options
3.3. Groovy Filter Processor
3.3.1. Options
3.4. Groovy Transform Processor
3.4.1. Options
3.5. Http Client Processor
3.5.1. Options
3.6. Scripable Transform Processor
3.6.1. Options
3.7. Splitter Processor
3.7.1. Options
3.7.2. JSON Example
3.8. Splitter Processor
3.8.1. Options
3.8.2. JSON Example
3.9. Transform Processor
3.9.1. Options
4. Sinks
4.1. Cassandra Sink
4.1.1. Options
4.2. Counter Sink
4.2.1. Options
4.3. Field Value Counter Sink
4.3.1. Options
4.4. File Sink
4.4.1. Options
4.5. FTP Sink
4.5.1. Options
4.6. Gemfire Sink
4.6.1. Options
4.7. Gpfdist Sink
4.7.1. Options
4.7.2. Implementation Notes
4.7.3. Detailed Option Descriptions
4.7.4. How Data Is Sent Into Segments
4.7.5. Example Usage
4.7.6. Tuning Transfer Rate
4.8. HDFS Sink
4.8.1. Options
4.9. Jdbc Sink
4.9.1. Options
4.10. Log Sink
4.10.1. Options
4.11. RabbitMQ Sink
4.11.1. Options
4.12. Redis Sink
4.12.1. Options
4.13. Router Sink
4.13.1. Options
4.13.2. SpEL-based Routing
4.13.3. Groovy-based Routing
4.14. TCP Sink
4.14.1. Options
4.14.2. Available Encoders
4.15. Throughput Sink
4.16. Websocket Sink
4.16.1. Options
4.16.2. Example
Step 1: Start Redis
Step 2: Deploy a time-source
Step 3: Deploy a websocket-sink
4.16.3. Actuators
III. Appendices
A. Building
A.1. Basic Compile and Test
A.2. Documentation
A.3. Working with the code
A.3.1. Importing into eclipse with m2eclipse
A.3.2. Importing into eclipse without m2eclipse
5. Contributing
5.1. Sign the Contributor License Agreement
5.2. Code Conventions and Housekeeping