Spring Cloud Stream App Starters
Einstein.SR9Spring Cloud Stream Application Starters are standalone executable applications that communicate over messaging middleware such as Apache Kafka and RabbitMQ. These applications can run independently on variety of runtime platforms including: Cloud Foundry, Apache Yarn, Apache Mesos, Kubernetes, Docker, or even on your laptop.
Features
-
Run standalone as Spring Boot applications
-
Compose microservice as streaming pipelines in Spring Cloud Data Flow
-
Consume microservice applications as maven or docker artifacts
-
Override configuration parameters via command-line, environment variables, or YAML file
-
Provide infrastructure to test the applications in isolation
-
Download as starters from this version of Spring Initializr
Available Applications
Source | Processor | Sink |
---|---|---|
twitter-sentiment /tensorflow/ |
||
image-recognition /tensorflow/ |
||
object-detection /tensorflow/ |
||
pose-estimation /tensorflow/ |
||
Stream App Starters and Spring Cloud Data Flow (**)
With Spring Boot 2.1.x + Spring Cloud Stream 2.1.x:
Artifact Type | Stable Release | Snapshot Release |
---|---|---|
RabbitMQ + Maven |
https://dataflow.spring.io/Einstein-BUILD-SNAPSHOT-stream-applications-rabbit-maven |
|
RabbitMQ + Docker |
https://dataflow.spring.io/Einstein-BUILD-SNAPSHOT-stream-applications-rabbit-docker |
|
Apache Kafka + Maven |
https://dataflow.spring.io/Einstein-BUILD-SNAPSHOT-stream-applications-kafka-maven |
|
Apache Kafka + Docker |
https://dataflow.spring.io/Einstein-BUILD-SNAPSHOT-stream-applications-kafka-docker |
(**) find out how to use the app-starters in Spring Cloud Data Flow by reviewing the app-registration section in the reference guide
Spring Boot Config
Step 1 - Download the latest time-source application from here [eg: /2.1.4.RELEASE/time-source-kafka-2.1.4.RELEASE.jar]
Step 2 - Download the latest log-sink application from here [eg: /2.1.5.RELEASE/log-sink-kafka-2.1.5.RELEASE.jar]
Step 3 - Start Kafka
Step 4 - Run Time Source and Bind to ticktock Topic
java -jar time-source-kafka-***.jar --spring.cloud.stream.bindings.output.destination=ticktock
Step 5 - Run Log Sink and Bind to ticktock Topic
java -jar log-sink-kafka-***.jar --spring.cloud.stream.bindings.input.destination=ticktock
Step 6 - Verify ticktock ouput in log-sink
console
Documentation
Einstein.SR9 CURRENT GA | Reference Doc. | API Doc. |
Einstein.SR8 GA | Reference Doc. | API Doc. |
Einstein.BUILD-SNAPSHOT SNAPSHOT | Reference Doc. | API Doc. |
Darwin.SR3 GA | Reference Doc. | API Doc. |
Darwin.BUILD-SNAPSHOT SNAPSHOT | Reference Doc. | API Doc. |
Celsius.SR3 GA | Reference Doc. | API Doc. |