Spring Cloud Stream Applications 2021.0.1
2021.0.1 release for Spring Cloud Stream applications and their corresponding functions (wherever applicable).
See below for details.
Bulk update links for Spring Cloud Data Flow
The following files are specifically intended to be used on Spring Cloud Data Flow for bulk importing the applications.
Kafka Applications - Harbor Registry
Rabbit Applications - Harbor Registry
HTTP Maven links for the apps and metadata
The following links are convenient ways to download individual applications and their metadata using tools like wget, curl etc.
You can look at these files and copy individual application links.
Dependent Projects and Compatibility
| Component | Version |
|---|---|
| Spring Boot | 2.5.5 |
| Spring Cloud | 2020.0.4 |
| Spring Cloud Stream | 3.1.5 |
| Spring Cloud Function | 3.1.5 |
| Spring Integration | 5.5.4 |
| Spring Kafka | 2.7.7 |
| Apps plugin (spring-cloud-dataflow-apps-generator-plugin) | 1.0.5 |
| Metadata plugin (spring-cloud-dataflow-apps-metadata-plugin) | 1.0.5 |
| Docs plugin (spring-cloud-dataflow-apps-docs-plugin) | 1.0.5 |
Binder-based uber jar apps for both Apache Kafka and RabbitMQ binders.
Download from Artifactory: https://repo.maven.apache.org/maven2/org/springframework/cloud/stream/app
Docker Hub: https://hub.docker.com/u/springcloudstream
Source Applications and Supplier Functions
| Artifact | Version | Corresponding Supplier | Version |
|---|---|---|---|
| cdc-debezium-source | 3.1.1 | cdc-debezium-supplier | 1.1.1 |
| file-source | 3.1.1 | file-supplier | 1.1.1 |
| ftp-source | 3.1.1 | ftp-supplier | 1.1.1 |
| geode-source | 3.1.1 | geode-supplier | 1.1.1 |
| http-source | 3.1.1 | http-supplier | 1.1.1 |
| jdbc-source | 3.1.1 | jdbc-supplier | 1.1.1 |
| jms-source | 3.1.1 | jms-supplier | 1.1.1 |
| load-generator-source | 3.1.1 | ||
| mail-source | 3.1.1 | mail-supplier | 1.1.1 |
| mongodb-source | 3.1.1 | mongodb-supplier | 1.1.1 |
| mqtt-source | 3.1.1 | mqtt-supplier | 1.1.1 |
| rabbit-source | 3.1.1 | rabbit-supplier | 1.1.1 |
| s3-source | 3.1.1 | s3-supplier | 1.1.1 |
| sftp-source | 3.1.1 | sftp-supplier | 1.1.1 |
| syslog-source | 3.1.1 | syslog-supplier | 1.1.1 |
| tcp-source | 3.1.1 | tcp-supplier | 1.1.1 |
| time-source | 3.1.1 | time-supplier | 1.1.1 |
| twitter-message-source | 3.1.1 | twitter-supplier | 1.1.1 |
| twitter-search-source | 3.1.1 | twitter-supplier | 1.1.1 |
| twitter-stream-source | 3.1.1 | twitter-supplier | 1.1.1 |
| websocket-source | 3.1.1 | websocket-supplier | 1.1.1 |
| zeromq-source | 3.1.1 | zeromq-supplier | 1.1.1 |
Sink Applications and Consumer Functions
| Artifact | Version | Corresponding Consumer/Function | Version |
|---|---|---|---|
| cassandra-sink | 3.1.1 | cassandra-consumer | 1.1.1 |
| analytics-sink | 3.1.1 | analytics-consumer | 1.1.1 |
| elasticsearch-sink | 3.1.1 | elasticsearch-consumer | 1.1.1 |
| file-sink | 3.1.1 | file-consumer | 1.1.1 |
| ftp-sink | 3.1.1 | ftp-consumer | 1.1.1 |
| geode-sink | 3.1.1 | geode-consumer | 1.1.1 |
| jdbc-sink | 3.1.1 | jdbc-consumer | 1.1.1 |
| log-sink | 3.1.1 | log-consumer | 1.1.1 |
| mongodb-sink | 3.1.1 | mongodb-consumer | 1.1.1 |
| mqtt-sink | 3.1.1 | mqtt-consumer | 1.1.1 |
| pgcopy-sink | 3.1.1 | ||
| rabbit-sink | 3.1.1 | rabbit-consumer | 1.1.1 |
| redis-sink | 3.1.1 | redis-consumer | 1.1.1 |
| router-sink | 3.1.1 | ||
| rsocket-sink | 3.1.1 | rsocket-consumer | 1.1.1 |
| s3-sink | 3.1.1 | s3-consumer | 1.1.1 |
| sftp-sink | 3.1.1 | sftp-consumer | 1.1.1 |
| tcp-sink | 3.1.1 | tcp-consumer | 1.1.1 |
| throughput-sink | 3.1.1 | ||
| twitter-message-sink | 3.1.1 | twitter-consumer | 1.1.1 |
| twitter-update-sink | 3.1.1 | twitter-consumer | 1.1.1 |
| wavefront-sink | 3.1.1 | wavefront-consumer | 1.1.1 |
| websocket-sink | 3.1.1 | websocket-consumer | 1.1.1 |
| zeromq-sink | 3.1.1 | zeromq-consumer | 1.1.1 |
Processor Applications and Functions
| Artifact | Version | Corresponding Function | Version |
|---|---|---|---|
| aggregator-processor | 3.1.1 | aggregator-function | 1.1.1 |
| bridge-processor | 3.1.1 | ||
| filter-processor | 3.1.1 | filter-function | 1.1.1 |
| groovy-processor | 3.1.1 | ||
| header-enricher-processor | 3.1.1 | header-enricher-function | 1.1.1 |
| http-request-processor | 3.1.1 | http-request-function | 1.1.1 |
| image-recognition-processor | 3.1.1 | image-recognition-function | 1.1.1 |
| objejct-detection-processor | 3.1.1 | objejct-detection-function | 1.1.1 |
| script-processor | 3.1.1 | ||
| semantic-segmentation-processor | 3.1.1 | semantic-segmentation-function | 1.1.1 |
| splitter-processor | 3.1.1 | splitter-function | 1.1.1 |
| transform-processor | 3.1.1 | spel-function | 1.1.1 |
| twitter-trend-processor | 3.1.1 | twitter-function | 1.1.1 |