领先一步
VMware 提供培训和认证,助您加速进步。
了解更多Spring Cloud Stream Applications 是独立的、可执行的应用程序,它们通过 Apache Kafka 和 RabbitMQ 等消息中间件进行通信。
这些应用程序可以独立运行在各种运行时平台上,包括 Kubernetes、Docker、Cloud Foundry,甚至您的笔记本电脑上。
即用型应用程序,可作为独立的 Spring Boot 应用程序运行。
在 Spring Cloud Data Flow 中将一组应用程序组装成一个连贯的流数据管道。
通过应用程序属性、环境变量或 YAML 文件覆盖配置参数。
您可以在此处找到可用应用程序的列表。
步骤 1 - 从此处下载最新的 time-source 应用程序(例如:5.1.2-SNAPSHOT)
步骤 2 - 从此处下载最新的 log-sink 应用程序(例如:5.1.2-SNAPSHOT)
步骤 3 - 启动 Kafka
步骤 4 - 启动时间源生产者应用程序,指向 Kafka 中的 ticktock 主题
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 日志中的 ticktock 输出
通过查阅参考指南中的应用程序注册部分,了解如何在 Spring Cloud Data Flow 中使用这些应用程序。
以下链接是使用 wget、curl 等工具下载单个应用程序和元数据的便捷方式。您可以查看这些文件并复制单个应用程序链接。
| 版本:Boot / Stream | Rabbit MQ | Apache Kafka |
|---|---|---|
| Spring Boot 3.1.12 / Spring Cloud Stream 4.0.5 | 稳定版 / 最新快照 | 稳定版 / 最新快照 |
| Spring Boot 3.3.8 / Spring Cloud Stream 4.1.5 | 稳定版 / 最新快照 | 稳定版 / 最新快照 |
| Spring Boot 3.4.10 / Spring Cloud Stream 4.2.2 | 稳定版 / 最新快照 | 稳定版 / 最新快照 |