Releases: spring-cloud/stream-applications
Releases · spring-cloud/stream-applications
Spring Cloud Stream Applications 2024.0.0
What's Changed
- Updating Contributing.adoc by @corneil in #539
- Update table of available apps by @onobc in #540
- Add spring.binders for SCSt test binder by @onobc in #544
🔨 Dependency Upgrades
- Spring Functions Catalog 5.0.0
- Spring Boot to 3.3.0
- Spring Framework to 6.1.8
- Spring Cloud to 2023.0.2
- Spring Cloud Stream to 4.1.2
- Test containers to 1.19.8
- Commons Compress to 1.26.2
- Groovy to 4.0.21
- Spring Cloud AWS to 3.1.1
- Spring Cloud Starters bootstrap to 4.1.2
- Spring Integration AWS to 3.0.7
- Spring Cloud Stream Apps Plugin to 1.0.14
Full Changelog: v2024.0.0-RC1...v2024.0.0
Contributors
corneil and onobc
Assets 2
Spring Cloud Stream Applications 2024.0.0-RC1
What's Changed
Full Changelog: v2024.0.0-M1...v2024.0.0-RC1
Contributors
onobc
Assets 2
Stream Applications 2024.0.0-M1
What's Changed
- Fix scope of function-test-support dependency by @cachescrubber in #509
- Use new private release repo libs-release-staging by @onobc in #513
- Updated dependency versions. by @corneil in #518
- Update major version to 5.0.x by @onobc in #520
- Bump org.apache.commons:commons-compress from 1.21 to 1.26.0 in /functions/common/tensorflow-common by @dependabot in #521
- Migrate apps to Spring Functions Catalog by @artembilan in #523
- [AppsPlugin] Add ability to link to config props in docs plugin by @onobc in #527
- Link to function catalog docs for config props by @onobc in #526
New Contributors
- @cachescrubber made their first contribution in #509
Full Changelog: v2022.0.0...v2024.0.0-M1
Contributors
corneil, artembilan, and 3 other contributors
Assets 2
v5.0.0-M1
Spring Cloud Stream Applications v2022.0.0
This is the long-awaited 2022.0.0 release for Spring Cloud Stream applications.
This major release updates all applications to Spring Boot 3.1.x and Spring Cloud 2022.0.x (where applicable).
Please see the migration guide for more 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.
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 | 3.1.4 |
| Spring Framework | 6.0.12 |
| Spring Integration | 6.1.3 |
| Spring Cloud | 2022.0.4 |
| Spring Cloud Function | 4.0.4 |
| Spring Cloud Stream | 4.0.4 |
Issues
#500 Header serialization exception in aggregator processor with Redis
#496 Update to Spring Boot 3.1.4 on 9/21
#488 [rabbit-source-rabbit-3.2.1] Error Value too long for column "AUDIT_DATA CHARACTER VARYING(4000)"
#418 Use Redis Testcontainers in tests
#330 BinderAwareChannelResolver removed from SCSt
#329 EnableBinding/Sink removed from SCSt
#328 EmbeddedMongoAutoConfiguration removed from Spring Boot
#327 Test/SocketUtils replacement
#286 Revise HttpRequestFunctionConfiguration configuration in favor of auto-configured by Spring Boot WebClient.Builder
#276 Enable components for customization via @CustomizationAware
#270 Update mail-source/sink apps to use Greenmail
#253 Can't infer the SQL type to use for an instance of io.debezium.data.SpecialValueDecimal
#236 Ability to add external libs to generated apps
#235 Switch image creation from jib to Spring Boot maven plugin
#188 Upgrade CDC app with latest Debezium Engine API
#187 Switch to Pack/Kpack for container image generation
What's Changed
- Release 2021.1.2 (non-apps back to snapshots) by @onobc in #304
- Release 2021.1.2 (apps back to snapshots) by @onobc in #305
- Release 2021.1.2 (release train back to snapshots) by @onobc in #306
- Fix typo for elasticsearch-sink README by @Kim-Taesu in #310
- Bump mysql-connector-java from 8.0.16 to 8.0.28 in /applications/stream-applications-integration-tests by @dependabot in #309
- Update main to next version (4.0.0) by @onobc in #314
- Revise HttpRequestFunctionConfiguration configuration by @sunny151091 in #295
- GH-276 Apply ComponentCustomizer in other modules by @artembilan in #284
- Fix cdc-debezium-supplier README.adoc by @Kim-Taesu in #316
- Update Java to 11.0.16 by @corneil in #317
- Bump aws-java-sdk-s3 from 1.11.415 to 1.12.261 in /applications/stream-applications-integration-tests by @dependabot in #313
- Disable DB init for JDBC Source and Sink by @artembilan in #325
- Add create-containers.sh and download-apps.sh by @corneil in #331
- Remove geode and update sftp by @corneil in #345
- [SB3 Update] SftpConsumer + AWS S3 by @onobc in #347
- GH-348: Resolve knownHostsExpression to Resource by @artembilan in #349
- Remove geode from docs by @corneil in #354
- GH-369: Fix HeaderEnricher for no proxyBeanMethod by @artembilan in #376
- GH-373: Re-enable aggregator tests by @artembilan in #377
- GH-368: Update AWS code to the latest deps by @artembilan in #378
- GH-350: Upgrade SI Cassandra; re-enable tests by @artembilan in #381
- [Issues] Change http-request to non-reactive by @corneil in #402
- Xmpp supplier by @dmfrey in #403
- initial commit by @dmfrey in #413
- Remove all remnants of Geode by @onobc in #414
- [SB3] Update Elasticsearch Client. by @corneil in #416
- GH-327: Use TestSocketUtils from spring-test by @onobc in #420
- GH-370: Enable ScriptProcessor tests back by @artembilan in #419
- GH-330: Rework Router Sink for
StreamBridgeby @artembilan in #421 - Change Filter function to non-reactive. by @corneil in #432
- GH-431: Support sub-dirs in S3 Source by @artembilan in #433
- Clarify sftp-supplier docs by @onobc in #436
- Added header-filter function and processor. by @corneil in #443
- Fix ElasticsearchSink index name header by @onobc in #446
- Remove spring-cloud-sleuth by @onobc in #454
- Fix metrics export for Spring Boot 3.x by @onobc in #455
- Document how to configure debezium offsets by @tzolov in #457
- Factor out the Debezium Engine Builder auto-configuration by @tzolov in #459
- GH-441: Add
JsonBytesToMapfunction by @artembilan in #461 - Debezium version update and new mssql it test by @tzolov in #460
- Factor out debeiuzm builder into a function common autoconfig project by @tzolov in #463
- Remove legacy config properties metadata files by @onobc in #464
- GH-265: Add Kafka Publisher and Sink by @artembilan in #469
- Update to Spring Boot 3.1.0 by @onobc in #473
- GH-265: Add Kafka Supplier & Source by @artembilan in #474
- GH-475: Add some missed nested props for apps by @artembilan in #476
- Update Debezium to 2.3.0.CR1 by @tzolov in #480
- Upgrade debezium to 2.3.0.Final by @tzolov in #482
- Upgrade to AWS SDK v2 by @artembilan in #484
- Update
S3SourceTeststo use AWS SDK v2 by @artembilan in #486 - Upgrade debezium to 2.3.3.Final by @tzolov in http...
Contributors
corneil, sobychacko, and 8 other contributors
Assets 2
v2022.0.0 - Release Candidate 2
This release candidate updates the s3 source and sink to version 2.x of AWS SDK and version 3.x of Spring Cloud AWS.
What's Changed
- Release 2021.1.2 (non-apps back to snapshots) by @onobc in #304
- Release 2021.1.2 (apps back to snapshots) by @onobc in #305
- Release 2021.1.2 (release train back to snapshots) by @onobc in #306
- Fix typo for elasticsearch-sink README by @Kim-Taesu in #310
- Bump mysql-connector-java from 8.0.16 to 8.0.28 in /applications/stream-applications-integration-tests by @dependabot in #309
- Update main to next version (4.0.0) by @onobc in #314
- Revise HttpRequestFunctionConfiguration configuration by @sunny151091 in #295
- GH-276 Apply ComponentCustomizer in other modules by @artembilan in #284
- Fix cdc-debezium-supplier README.adoc by @Kim-Taesu in #316
- Update Java to 11.0.16 by @corneil in #317
- Bump aws-java-sdk-s3 from 1.11.415 to 1.12.261 in /applications/stream-applications-integration-tests by @dependabot in #313
- Disable DB init for JDBC Source and Sink by @artembilan in #325
- Add create-containers.sh and download-apps.sh by @corneil in #331
- Fix docs by @corneil in #332
- Updated to add filter by @corneil in #333
- Spring Boot 3.0 update - checkpoint 1 by @onobc in #336
- Added module poms by @corneil in #337
- Remove extension settings.xml by @onobc in #338
- Update create-containers.sh and download-apps.sh by @corneil in #339
- Corneil/add initial GitHub actions by @corneil in #340
- Adding redis-common and disable elasticsearch. by @corneil in #341
- Workflow update by @corneil in #342
- Workflow update by @corneil in #343
- update github actions by @corneil in #344
- Remove geode and update sftp by @corneil in #345
- [SB3 Update] SftpConsumer + AWS S3 by @onobc in #347
- GH-348: Resolve knownHostsExpression to Resource by @artembilan in #349
- [SB3 Update] many fixes toward unit tests by @onobc in #352
- [SB3 Update] more fixes towards unit tests by @onobc in #353
- Remove geode from docs by @corneil in #354
- [SB3 Update] even more fixes towards unit tests by @onobc in #355
- Use public snapshot and milestone for build. by @corneil in #356
- Require .settings.xml for deploy credentials. by @corneil in #357
- Reorganise modules by @corneil in #358
- Enable verbose by @corneil in #359
- Added dependencyManagement to .settings.xml by @corneil in #360
- Ensure module projects skip deploy by @corneil in #361
- Fix parameters to matrixes by @corneil in #362
- Reducing maven build time on apps by @corneil in #363
- Fix exporting env by @corneil in #364
- Fix build-app by @corneil in #365
- Fix build-app by @corneil in #366
- build app containers by @corneil in #374
- [SB3 Build] Adding dependencies to functions-dependencies. by @corneil in #375
- GH-369: Fix HeaderEnricher for no proxyBeanMethod by @artembilan in #376
- GH-373: Re-enable aggregator tests by @artembilan in #377
- GH-368: Update AWS code to the latest deps by @artembilan in #378
- Add script that uses pack to create a container by @corneil in #383
- Updated build to use packeto buildpacks to create a container. by @corneil in #384
- Fix error in yaml by @corneil in #385
- update .gitignore by @corneil in #386
- update build by @corneil in #387
- fix build by @corneil in #388
- fix build by @corneil in #389
- GH-350: Upgrade SI Cassandra; re-enable tests by @artembilan in #381
- default encoding utf8 by @corneil in #390
- added logging docker commands by @corneil in #391
- Fix publish and error reporting by @corneil in #392
- Improve error reporting by @corneil in #393
- Fix build app deploy by @corneil in #394
- [GitHub Actions] remove quotes from version by @corneil in #396
- [GitHub Actions] fix extracting Maven project version. Rename element… by @corneil in #397
- [GitHub Actions] fix core build by @corneil in #398
- [GitHub Actions] improve maven output by @corneil in #399
- [GitHub Actions] fix pack usage by @corneil in #400
- [Issues] Change http-request to non-reactive by @corneil in #402
- [SB 3] Fix checkstyle in http-request-function. by @corneil in #406
- Xmpp supplier by @dmfrey in #403
- Bump ivy from 2.4.0 to 2.5.1 in /applications/processor/groovy-processor by @dependabot in #409
- Bump ivy from 2.4.0 to 2.5.1 in /applications/sink/router-sink by @dependabot in #408
- Bump ivy from 2.4.0 to 2.5.1 in /applications/processor/script-processor by @dependabot in #407
- update for consistency by @dmfrey in #404
- update test configuration for consistency by @dmfrey in #412
- initial commit by @dmfrey in #413
- Remove all remnants of Geode by @onobc in #414
- Update to Spring Boot 3.0.0-RC2 / Spring Cloud 2022.0.0-RC1 by @onobc in #415
- [SB3] Update Elasticsearch Client. by @corneil in #416
- GH-327: Use TestSocketUtils from spring-test by @onobc in #420
- GH-370: Enable ScriptProcessor tests back by @artembilan in #419
- GH-330: Rework Router Sink for
StreamBridgeby @artembilan in #421 - Change Filter function to non-reactive. by @corneil in #432
- Remove spring-doc-resources-0.2.5.zip. by @corneil in #434
- GH-431: Support sub-dirs in S3 Source by @artembilan in #433
- Clarify sftp-supplier docs by @onobc in #436
- Remove invalid config props references by @onobc in https://github...
Contributors
corneil, dmfrey, and 6 other contributors
Assets 2
Spring Cloud Stream Applications 2021.1.2
2021.1.2 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.
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.6.8 |
| Spring Cloud | 2021.0.3 |
| Spring Cloud Stream | 3.2.4 |
| Spring Cloud Function | 3.2.5 |
| Spring Integration | 5.5.12 |
| Spring Kafka | 2.8.6 |
| Apps plugin (spring-cloud-dataflow-apps-generator-plugin) | 1.0.7 |
| Metadata plugin (spring-cloud-dataflow-apps-metadata-plugin) | 1.0.7 |
| Docs plugin (spring-cloud-dataflow-apps-docs-plugin) | 1.0.7 |
Binder-based uber jar apps for both Apache Kafka and RabbitMQ binders.
Download from Maven Central: 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.2.1 | cdc-debezium-supplier | 1.2.1 |
| file-source | 3.2.1 | file-supplier | 1.2.1 |
| ftp-source | 3.2.1 | ftp-supplier | 1.2.1 |
| geode-source | 3.2.1 | geode-supplier | 1.2.1 |
| http-source | 3.2.1 | http-supplier | 1.2.1 |
| jdbc-source | 3.2.1 | jdbc-supplier | 1.2.1 |
| jms-source | 3.2.1 | jms-supplier | 1.2.1 |
| load-generator-source | 3.2.1 | ||
| mail-source | 3.2.1 | mail-supplier | 1.2.1 |
| mongodb-source | 3.2.1 | mongodb-supplier | 1.2.1 |
| mqtt-source | 3.2.1 | mqtt-supplier | 1.2.1 |
| rabbit-source | 3.2.1 | rabbit-supplier | 1.2.1 |
| s3-source | 3.2.1 | s3-supplier | 1.2.1 |
| sftp-source | 3.2.1 | sftp-supplier | 1.2.1 |
| syslog-source | 3.2.1 | syslog-supplier | 1.2.1 |
| tcp-source | 3.2.1 | tcp-supplier | 1.2.1 |
| time-source | 3.2.1 | time-supplier | 1.2.1 |
| twitter-message-source | 3.2.1 | twitter-supplier | 1.2.1 |
| twitter-search-source | 3.2.1 | twitter-supplier | 1.2.1 |
| twitter-stream-source | 3.2.1 | twitter-supplier | 1.2.1 |
| websocket-source | 3.2.1 | websocket-supplier | 1.2.1 |
| zeromq-source | 3.2.1 | zeromq-supplier | 1.2.1 |
Sink Applications and Consumer Functions
| Artifact | Version | Corresponding Consumer/Function | Version |
|---|---|---|---|
| cassandra-sink | 3.2.1 | cassandra-consumer | 1.2.1 |
| analytics-sink | 3.2.1 | analytics-consumer | 1.2.1 |
| elasticsearch-sink | 3.2.1 | elasticsearch-consumer | 1.2.1 |
| file-sink | 3.2.1 | file-consumer | 1.2.1 |
| ftp-sink | 3.2.1 | ftp-consumer | 1.2.1 |
| geode-sink | 3.2.1 | geode-consumer | 1.2.1 |
| jdbc-sink | 3.2.1 | jdbc-consumer | 1.2.1 |
| log-sink | 3.2.1 | log-consumer | 1.2.1 |
| mongodb-sink | 3.2.1 | mongodb-consumer | 1.2.1 |
| mqtt-sink | 3.2.1 | mqtt-consumer | 1.2.1 |
| pgcopy-sink | 3.2.1 | ||
| rabbit-sink | 3.2.1 | rabbit-consumer | 1.2.1 |
| redis-sink | 3.2.1 | redis-consumer | 1.2.1 |
| router-sink | 3.2.1 | ||
| rsocket-sink | 3.2.1 | rsocket-consumer | 1.2.1 |
| s3-sink | 3.2.1 | s3-consumer | 1.2.1 |
| sftp-sink | 3.2.1 | sftp-consumer | 1.2.1 |
| tcp-sink | 3.2.1 | tcp-consumer | 1.2.1 |
| throughput-sink | 3.2.1 | ||
| twitter-message-sink | 3.2.1 | twitter-consumer | 1.2.1 |
| twitter-update-sink | 3.2.1 | twitter-consumer | 1.2.1 |
| wavefront-sink | 3.2.1 | wavefront-consumer | 1.2.1 |
| websocket-sink | 3.2.1 | websocket-consumer | 1.2.1 |
| zeromq-sink | 3.2.1 | zeromq-consumer | 1.2.1 |
Processor Applications and Functions
| Artifact | Version | Corresponding Function | Version |
|---|---|---|---|
| aggregator-processor | 3.2.1 | aggregator-function | 1.2.1 |
| bridge-processor | 3.2.1 | ||
| filter-processor | 3.2.1 | filter-function | 1.2.1 |
| groovy-processor | 3.2.1 | ||
| header-enricher-processor | 3.2.1 | header-enricher-function | 1.2.1 |
| http-request-processor | 3.2.1 | http-request-function | 1.2.1 |
| image-recognition-processor | 3.2.1 | image-recognition-function | 1.2.1 |
| objejct-detection-processor | 3.2.1 | objejct-detection-function | 1.2.1 |
| script-processor | 3.2.1 | ||
| semantic-segmentation-processor | 3.2.1 | semantic-segmentation-function | 1.2.1 |
| splitter-processor | 3.2.1 | splitter-function | 1.2.1 |
| transform-processor | 3.2.1 | spel-function | 1.2.1 |
| twitter-trend-processor | 3.2.1 | twitter-function | 1.2.1 |
Spring Cloud Stream Applications 2021.1.1
2021.1.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.
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.6.3 |
| Spring Cloud | 2021.0.1 |
| Spring Cloud Stream | 3.2.2 |
| Spring Cloud Function | 3.2.2 |
| Spring Integration | 5.5.8 |
| Spring Kafka | 2.8.2 |
| Apps plugin (spring-cloud-dataflow-apps-generator-plugin) | 1.0.6 |
| Metadata plugin (spring-cloud-dataflow-apps-metadata-plugin) | 1.0.6 |
| Docs plugin (spring-cloud-dataflow-apps-docs-plugin) | 1.0.6 |
Binder-based uber jar apps for both Apache Kafka and RabbitMQ binders.
Download from Maven Central: 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.2.0 | cdc-debezium-supplier | 1.2.0 |
| file-source | 3.2.0 | file-supplier | 1.2.0 |
| ftp-source | 3.2.0 | ftp-supplier | 1.2.0 |
| geode-source | 3.2.0 | geode-supplier | 1.2.0 |
| http-source | 3.2.0 | http-supplier | 1.2.0 |
| jdbc-source | 3.2.0 | jdbc-supplier | 1.2.0 |
| jms-source | 3.2.0 | jms-supplier | 1.2.0 |
| load-generator-source | 3.2.0 | ||
| mail-source | 3.2.0 | mail-supplier | 1.2.0 |
| mongodb-source | 3.2.0 | mongodb-supplier | 1.2.0 |
| mqtt-source | 3.2.0 | mqtt-supplier | 1.2.0 |
| rabbit-source | 3.2.0 | rabbit-supplier | 1.2.0 |
| s3-source | 3.2.0 | s3-supplier | 1.2.0 |
| sftp-source | 3.2.0 | sftp-supplier | 1.2.0 |
| syslog-source | 3.2.0 | syslog-supplier | 1.2.0 |
| tcp-source | 3.2.0 | tcp-supplier | 1.2.0 |
| time-source | 3.2.0 | time-supplier | 1.2.0 |
| twitter-message-source | 3.2.0 | twitter-supplier | 1.2.0 |
| twitter-search-source | 3.2.0 | twitter-supplier | 1.2.0 |
| twitter-stream-source | 3.2.0 | twitter-supplier | 1.2.0 |
| websocket-source | 3.2.0 | websocket-supplier | 1.2.0 |
| zeromq-source | 3.2.0 | zeromq-supplier | 1.2.0 |
Sink Applications and Consumer Functions
| Artifact | Version | Corresponding Consumer/Function | Version |
|---|---|---|---|
| cassandra-sink | 3.2.0 | cassandra-consumer | 1.2.0 |
| analytics-sink | 3.2.0 | analytics-consumer | 1.2.0 |
| elasticsearch-sink | 3.2.0 | elasticsearch-consumer | 1.2.0 |
| file-sink | 3.2.0 | file-consumer | 1.2.0 |
| ftp-sink | 3.2.0 | ftp-consumer | 1.2.0 |
| geode-sink | 3.2.0 | geode-consumer | 1.2.0 |
| jdbc-sink | 3.2.0 | jdbc-consumer | 1.2.0 |
| log-sink | 3.2.0 | log-consumer | 1.2.0 |
| mongodb-sink | 3.2.0 | mongodb-consumer | 1.2.0 |
| mqtt-sink | 3.2.0 | mqtt-consumer | 1.2.0 |
| pgcopy-sink | 3.2.0 | ||
| rabbit-sink | 3.2.0 | rabbit-consumer | 1.2.0 |
| redis-sink | 3.2.0 | redis-consumer | 1.2.0 |
| router-sink | 3.2.0 | ||
| rsocket-sink | 3.2.0 | rsocket-consumer | 1.2.0 |
| s3-sink | 3.2.0 | s3-consumer | 1.2.0 |
| sftp-sink | 3.2.0 | sftp-consumer | 1.2.0 |
| tcp-sink | 3.2.0 | tcp-consumer | 1.2.0 |
| throughput-sink | 3.2.0 | ||
| twitter-message-sink | 3.2.0 | twitter-consumer | 1.2.0 |
| twitter-update-sink | 3.2.0 | twitter-consumer | 1.2.0 |
| wavefront-sink | 3.2.0 | wavefront-consumer | 1.2.0 |
| websocket-sink | 3.2.0 | websocket-consumer | 1.2.0 |
| zeromq-sink | 3.2.0 | zeromq-consumer | 1.2.0 |
Processor Applications and Functions
| Artifact | Version | Corresponding Function | Version |
|---|---|---|---|
| aggregator-processor | 3.2.0 | aggregator-function | 1.2.0 |
| bridge-processor | 3.2.0 | ||
| filter-processor | 3.2.0 | filter-function | 1.2.0 |
| groovy-processor | 3.2.0 | ||
| header-enricher-processor | 3.2.0 | header-enricher-function | 1.2.0 |
| http-request-processor | 3.2.0 | http-request-function | 1.2.0 |
| image-recognition-processor | 3.2.0 | image-recognition-function | 1.2.0 |
| objejct-detection-processor | 3.2.0 | objejct-detection-function | 1.2.0 |
| script-processor | 3.2.0 | ||
| semantic-segmentation-processor | 3.2.0 | semantic-segmentation-function | 1.2.0 |
| splitter-processor | 3.2.0 | splitter-function | 1.2.0 |
| transform-processor | 3.2.0 | spel-function | 1.2.0 |
| twitter-trend-processor | 3.2.0 | twitter-function | 1.2.0 |
Spring Cloud Stream Applications 2021.1.0
2021.1.0 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.
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.6.3 |
| Spring Cloud | 2021.0.1 |
| Spring Cloud Stream | 3.2.2 |
| Spring Cloud Function | 3.2.2 |
| Spring Integration | 5.5.8 |
| Spring Kafka | 2.8.2 |
| Apps plugin (spring-cloud-dataflow-apps-generator-plugin) | 1.0.6 |
| Metadata plugin (spring-cloud-dataflow-apps-metadata-plugin) | 1.0.6 |
| Docs plugin (spring-cloud-dataflow-apps-docs-plugin) | 1.0.6 |
Binder-based uber jar apps for both Apache Kafka and RabbitMQ binders.
Download from Maven Central: 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.2.0 | cdc-debezium-supplier | 1.2.0 |
| file-source | 3.2.0 | file-supplier | 1.2.0 |
| ftp-source | 3.2.0 | ftp-supplier | 1.2.0 |
| geode-source | 3.2.0 | geode-supplier | 1.2.0 |
| http-source | 3.2.0 | http-supplier | 1.2.0 |
| jdbc-source | 3.2.0 | jdbc-supplier | 1.2.0 |
| jms-source | 3.2.0 | jms-supplier | 1.2.0 |
| load-generator-source | 3.2.0 | ||
| mail-source | 3.2.0 | mail-supplier | 1.2.0 |
| mongodb-source | 3.2.0 | mongodb-supplier | 1.2.0 |
| mqtt-source | 3.2.0 | mqtt-supplier | 1.2.0 |
| rabbit-source | 3.2.0 | rabbit-supplier | 1.2.0 |
| s3-source | 3.2.0 | s3-supplier | 1.2.0 |
| sftp-source | 3.2.0 | sftp-supplier | 1.2.0 |
| syslog-source | 3.2.0 | syslog-supplier | 1.2.0 |
| tcp-source | 3.2.0 | tcp-supplier | 1.2.0 |
| time-source | 3.2.0 | time-supplier | 1.2.0 |
| twitter-message-source | 3.2.0 | twitter-supplier | 1.2.0 |
| twitter-search-source | 3.2.0 | twitter-supplier | 1.2.0 |
| twitter-stream-source | 3.2.0 | twitter-supplier | 1.2.0 |
| websocket-source | 3.2.0 | websocket-supplier | 1.2.0 |
| zeromq-source | 3.2.0 | zeromq-supplier | 1.2.0 |
Sink Applications and Consumer Functions
| Artifact | Version | Corresponding Consumer/Function | Version |
|---|---|---|---|
| cassandra-sink | 3.2.0 | cassandra-consumer | 1.2.0 |
| analytics-sink | 3.2.0 | analytics-consumer | 1.2.0 |
| elasticsearch-sink | 3.2.0 | elasticsearch-consumer | 1.2.0 |
| file-sink | 3.2.0 | file-consumer | 1.2.0 |
| ftp-sink | 3.2.0 | ftp-consumer | 1.2.0 |
| geode-sink | 3.2.0 | geode-consumer | 1.2.0 |
| jdbc-sink | 3.2.0 | jdbc-consumer | 1.2.0 |
| log-sink | 3.2.0 | log-consumer | 1.2.0 |
| mongodb-sink | 3.2.0 | mongodb-consumer | 1.2.0 |
| mqtt-sink | 3.2.0 | mqtt-consumer | 1.2.0 |
| pgcopy-sink | 3.2.0 | ||
| rabbit-sink | 3.2.0 | rabbit-consumer | 1.2.0 |
| redis-sink | 3.2.0 | redis-consumer | 1.2.0 |
| router-sink | 3.2.0 | ||
| rsocket-sink | 3.2.0 | rsocket-consumer | 1.2.0 |
| s3-sink | 3.2.0 | s3-consumer | 1.2.0 |
| sftp-sink | 3.2.0 | sftp-consumer | 1.2.0 |
| tcp-sink | 3.2.0 | tcp-consumer | 1.2.0 |
| throughput-sink | 3.2.0 | ||
| twitter-message-sink | 3.2.0 | twitter-consumer | 1.2.0 |
| twitter-update-sink | 3.2.0 | twitter-consumer | 1.2.0 |
| wavefront-sink | 3.2.0 | wavefront-consumer | 1.2.0 |
| websocket-sink | 3.2.0 | websocket-consumer | 1.2.0 |
| zeromq-sink | 3.2.0 | zeromq-consumer | 1.2.0 |
Processor Applications and Functions
| Artifact | Version | Corresponding Function | Version |
|---|---|---|---|
| aggregator-processor | 3.2.0 | aggregator-function | 1.2.0 |
| bridge-processor | 3.2.0 | ||
| filter-processor | 3.2.0 | filter-function | 1.2.0 |
| groovy-processor | 3.2.0 | ||
| header-enricher-processor | 3.2.0 | header-enricher-function | 1.2.0 |
| http-request-processor | 3.2.0 | http-request-function | 1.2.0 |
| image-recognition-processor | 3.2.0 | image-recognition-function | 1.2.0 |
| objejct-detection-processor | 3.2.0 | objejct-detection-function | 1.2.0 |
| script-processor | 3.2.0 | ||
| semantic-segmentation-processor | 3.2.0 | semantic-segmentation-function | 1.2.0 |
| splitter-processor | 3.2.0 | splitter-function | 1.2.0 |
| transform-processor | 3.2.0 | spel-function | 1.2.0 |
| twitter-trend-processor | 3.2.0 | twitter-function | 1.2.0 |
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 |