Spring Cloud Stream 应用2025.0.0

Spring Cloud Stream Applications 是独立可执行的应用，它们通过消息中间件（如 Apache Kafka 和 RabbitMQ）进行通信。

这些应用可以独立运行在各种运行时平台，包括 Kubernetes, Docker, Cloud Foundry，甚至您自己的笔记本电脑上。

特性

• 开箱即用的应用，可作为独立的 Spring Boot 应用运行。

• 在 Spring Cloud Data Flow 中将一组应用组合成一个连贯的流式数据管道。

• 通过应用属性、环境变量或 YAML 文件覆盖配置参数。

可用应用

您可以在此处找到可用应用的列表。

快速入门

步骤 1 - 从此处下载最新的 time-source 应用（例如: 4.0.1-SNAPSHOT）

步骤 2 - 从此处下载最新的 log-sink 应用（例如: 4.0.1-SNAPSHOT）

步骤 3 - 启动 Kafka

步骤 4 - 启动 Time Source 生产者应用，指向 Kafka 中的 ticktock 主题

java -jar time-source-kafka-***.jar --spring.cloud.stream.bindings.output.destination=ticktock

步骤 5 - 启动 Log Sink 消费者应用，指向 Kafka 中的 ticktock 主题

java -jar log-sink-kafka-***.jar --spring.cloud.stream.bindings.input.destination=ticktock --server.port=0

步骤 6 - 在 log-sink 日志中验证 ticktock 输出

Stream 应用与 Spring Cloud Data Flow

通过查阅参考指南中的应用注册部分，了解如何在 Spring Cloud Data Flow 中使用这些应用。

应用的 HTTP 仓库位置

以下链接是使用 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.2 / Spring Cloud Stream 4.2.0	稳定版 / 最新快照版	稳定版 / 最新快照版

相关项目

• Spring Cloud Stream

• Spring Cloud Data Flow

• Spring Cloud Task