Spring Cloud Stream 应用2022.0.0

Spring Cloud Stream 应用是独立可执行的应用程序，它们通过消息中间件（例如 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 - 启动指向 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 - 验证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.4 / Spring Cloud Stream 4.0.4	稳定版 / 最新快照版	稳定版 / 最新快照版
Spring Boot 2.6.8 / Spring Cloud Stream 3.2.4	稳定版 / 最新快照版	稳定版 / 最新快照版

相关项目

• Spring Cloud Stream

• Spring Cloud Data Flow

• Spring Cloud Task