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 数据流
通过查看参考指南中的应用注册部分,了解如何在 Spring Cloud Data Flow 中使用应用。
应用程序的 HTTP 存储库位置
以下链接是使用等工具下载单个应用程序和元数据的便捷方法。
您可以查看这些文件并复制单个应用程序链接。wget
curl