close

Spring Cloud Stream App Starters

Einstein SR6

Spring 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

cdc-debezium

aggregator

cassandra

file

bridge

counter

ftp

counter

file

gemfire

filter

ftp

gemfire-cq

groovy-filter

gemfire

http

groovy-transform

gpfdist

jdbc

grpc

hdfs

jms

header-enricher

jdbc

load-generator

httpclient

log

loggregator

pmml

rabbit

mail

python-http

mongodb

mongodb

python-jython

mqtt

mqtt

scripable-transform

pgcopy

rabbit

splitter

redis

s3

tasklauncherrequest-transform

router

sftp

tcp-client

s3

sftp-dataflow

transform

sftp

syslog

tensorFlow

tcp

tcp

twitter-sentiment /tensorflow/

throughput

tcp-client

image-recognition /tensorflow/

websocket

time

object-detection /tensorflow/

task-launcher-dataflow

trigger

pose-estimation /tensorflow/

triggertask

twitterstream

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/rabbit-maven-latest

https://dataflow.spring.io/Einstein-BUILD-SNAPSHOT-stream-applications-rabbit-maven

RabbitMQ + Docker

https://dataflow.spring.io/rabbit-docker-latest

https://dataflow.spring.io/Einstein-BUILD-SNAPSHOT-stream-applications-rabbit-docker

Apache Kafka + Maven

https://dataflow.spring.io/kafka-maven-latest

https://dataflow.spring.io/Einstein-BUILD-SNAPSHOT-stream-applications-kafka-maven

Apache Kafka + Docker

https://dataflow.spring.io/kafka-docker-latest

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

HTTP Repository Location for Apps

Versions: Boot / Stream Rabbit MQ Apache Kafka

Spring Boot 2.1.x / Spring Cloud Stream 2.1.x

Stable Release / Latest Snapshot

Stable Release / Latest Snapshot

Spring Boot Config

Step 1 - Download the latest time-source application from here [eg: /2.1.2.RELEASE/time-source-kafka-2.1.2.RELEASE.jar]

Step 2 - Download the latest log-sink application from here [eg: /2.1.3.RELEASE/log-sink-kafka-2.1.3.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

Spring Initializr

Quickstart Your Project

Bootstrap your application with Spring Initializr.

Documentation

Each Spring project has its own; it explains in great details how you can use project features and what you can achieve with them.
Einstein SR6 CURRENT GA Reference Doc. API Doc.
Einstein SNAPSHOT Reference Doc. API Doc.
Darwin SR3 GA Reference Doc. API Doc.
Darwin SNAPSHOT Reference Doc. API Doc.
Celsius SR3 GA Reference Doc. API Doc.