Get ahead
VMware offers training and certification to turbo-charge your progress.
Learn moreSpring Cloud Stream Applications are standalone executable applications that communicate over messaging middleware such as Apache Kafka and RabbitMQ.
These applications can run independently on a variety of runtime platforms, including Kubernetes, Docker, Cloud Foundry, or even on your laptop.
Out-of-the-box applications ready to run as standalone Spring Boot applications.
Assemble a set of applications into a coherent streaming data pipeline in Spring Cloud Data Flow.
Override configuration parameters via application properties, environment variables, or in the YAML file.
Step 1 - Download the latest time-source application from here (eg: 3.2.2-SNAPSHOT
)
Step 2 - Download the latest log-sink application from here (eg: 3.2.2-SNAPSHOT
)
Step 3 - Start Kafka
Step 4 - Start the Time Source producer application pointing to ticktock topic in Kafka
java -jar time-source-kafka-***.jar --spring.cloud.stream.bindings.output.destination=ticktock
Step 5 - Start the Log Sink consumer application pointing to ticktock topic in Kafka
java -jar log-sink-kafka-***.jar --spring.cloud.stream.bindings.input.destination=ticktock --server.port=0
Step 6 - Verify ticktock output in the log-sink
logs
Artifact Type | Stable Release | Snapshot Release |
---|---|---|
RabbitMQ + Maven | https://dataflow.spring.io/rabbitmq-maven-latest | https://dataflow.spring.io/rabbitmq-maven-latest-snapshot |
RabbitMQ + Docker | https://dataflow.spring.io/rabbitmq-docker-latest | https://dataflow.spring.io/rabbitmq-docker-latest-snapshot |
Apache Kafka + Maven | https://dataflow.spring.io/kafka-maven-latest | https://dataflow.spring.io/kafka-maven-latest-snapshot |
Apache Kafka + Docker | https://dataflow.spring.io/kafka-docker-latest | https://dataflow.spring.io/kafka-docker-latest-snapshot |
(**) find out how to use the apps in Spring Cloud Data Flow by reviewing the app-registration section in the reference guide
Versions: Boot / Stream | Rabbit MQ | Apache Kafka |
---|---|---|
Spring Boot 2.6.8 / Spring Cloud Stream 3.2.4 | Stable Release / Latest Snapshot | Stable Release / Latest Snapshot |