Spring Cloud Stream 应用程序是独立的可执行应用程序,它们通过消息传递中间件(如 Apache Kafka 和 RabbitMQ)进行通信。
这些应用程序可以在各种运行时平台上独立运行,包括 Kubernetes、Docker、Cloud Foundry,甚至在您的笔记本电脑上。
特征
-
开箱即用的应用程序,可作为独立的 Spring Boot 应用程序运行。
-
在 Spring Cloud Data Flow 中将一组应用程序组装到一个连贯的流数据管道中。
-
通过应用程序属性、环境变量或 YAML 文件覆盖配置参数。
可用应用
您可以在此处找到可用应用程序的列表。
快速开始
第 1 步 - 从此处下载最新的时间源应用程序(例如:4.0.1-SNAPSHOT
)
第 2 步 - 从这里下载最新的 log-sink 应用程序(例如:4.0.1-SNAPSHOT
)
第 3 步 - 启动 Kafka
第 4 步 - 启动指向 Kafka 中的 ticktock 主题的 Time Source 创建者应用程序
java -jar time-source-kafka-***.jar --spring.cloud.stream.bindings.output.destination=ticktock
第 5 步 - 启动指向 Kafka 中的 ticktock 主题的 Log Sink 使用者应用程序
java -jar log-sink-kafka-***.jar --spring.cloud.stream.bindings.input.destination=ticktock --server.port=0
第 6 步 - 验证日志中的 ticktock 输出log-sink
流式处理应用程序和 Spring Cloud 数据流
通过查看参考指南中的 app-registration 部分,了解如何在 Spring Cloud Data Flow 中使用应用程序。
应用程序的 HTTP 存储库位置
以下链接是使用 等工具下载单个应用程序和元数据的便捷方法。
您可以查看这些文件并复制各个应用程序链接。wget
curl
版本: Boot / Stream |
兔子 MQ |
Apache Kafka |
Spring Boot 3.1.12 / Spring Cloud Stream 4.0.5 |
稳定版 / 最新快照 |
稳定版 / 最新快照 |
Spring Boot 3.3.0 / Spring Cloud Stream 4.1.2 |
稳定版 / 最新快照 |
稳定版 / 最新快照 |