Spring Cloud Stream 应用是独立的可执行应用程序,通过消息中间件如 Apache Kafka 和 RabbitMQ 进行通信。
这些应用程序可以独立运行在多种运行时平台上,包括 Kubernetes、Docker、Cloud Foundry,甚至在你的笔记本电脑上。
特征
-
开箱即用的应用程序,可以作为独立的 Spring Boot 应用程序运行。
-
在 Spring Cloud Data Flow 中将一组应用组装成一个连贯的流式数据流式管道。
-
通过应用程序属性、环境变量或 YAML 文件来覆盖配置参数。
可用应用
你可以在这里找到可用申请名单。
快速入门
步骤1 - 从这里下载最新的时间源应用(例如:5.1.2-SNAPSHOT)
步骤2 - 从这里下载最新的日志汇入应用(例如:5.1.2-SNAPSHOT)
第三步——开始写卡夫卡
步骤4 - 启动指向 Kafka 中滴答题题的时间源生产应用程序
java -jar time-source-kafka-***.jar --spring.cloud.stream.bindings.output.destination=ticktock
步骤5 - 启动指向 Kafka 中 ticktock 主题的日志汇入消费者应用程序
java -jar log-sink-kafka-***.jar --spring.cloud.stream.bindings.input.destination=ticktock --server.port=0
步骤6 - 在日志中验证滴答输出log-sink
Stream Applications 与 Spring Cloud 数据流
通过参考指南中的应用注册部分,了解如何使用春季云数据流中的应用。
应用的HTTP仓库位置
以下链接是使用诸如 等工具下载单个应用程序和元数据的便捷方式。
你可以查看这些文件并复制单个申请链接。wgetcurl