Spring Cloud Stream 应用程序2022.0.0

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

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

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

快速入门

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

步骤 2 - 从 此处 下载最新的log-sink应用程序（例如：4.0.1-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

通过查看参考指南中的 app-registration 部分，了解如何在 Spring Cloud Data Flow 中使用应用程序。

用于应用程序的 HTTP 存储库位置

以下链接是使用诸如 wget、curl 等工具下载单个应用程序和元数据的一种便捷方式。您可以查看这些文件并复制单个应用程序链接。

版本：Boot / Stream	Rabbit MQ	Apache Kafka
Spring Boot 3.1.4 / Spring Cloud Stream 4.0.4	稳定版本 / 最新快照	稳定版本 / 最新快照
Spring Boot 2.6.8 / Spring Cloud Stream 3.2.4	稳定版本 / 最新快照	稳定版本 / 最新快照

相关项目

• Spring Cloud Stream

• Spring Cloud 数据流

• Spring Cloud Task