Spring Cloud Stream Applications Einstein SR5

本文介绍Spring Cloud Stream应用,一种可独立运行并基于Apache Kafka和RabbitMQ等消息中间件通信的应用。涵盖从下载时间源应用到启动日志接收器的快速开始指南,以及如何在Spring Cloud Data Flow中构建数据流管道。

摘要生成于 C知道 ,由 DeepSeek-R1 满血版支持, 前往体验 >

Spring Cloud Stream Applications are standalone executable applications that communicate over messaging middleware such as Apache Kafka and RabbitMQ.

These applications can run independently on a variety of runtime platforms, including Kubernetes, Docker, Cloud Foundry, or even on your laptop.
Features

Out-of-the-box applications ready to run as standalone Spring Boot applications.

Assemble a set of applications into a coherent streaming data pipeline in Spring Cloud Data Flow.

Override configuration parameters via application properties, environment variables, or in the YAML file.

Available Applications

Source

Processor

Sink

Time

Splitter

Log

HTTP

Rabbitmq

JDBC

Quick Start

Step 1 - Download the latest time-source application from here [eg: /3.0.0.BUILD-SNAPSHOT/time-source-kafka-3.0.0.BUILD-SNAPSHOT.jar]

Step 2 - Download the latest log-sink application from here [eg: /3.0.0.BUILD-SNAPSHOT/log-sink-kafka-3.0.0.BUILD-SNAPSHOT.jar]

Step 3 - Start Kafka

Step 4 - Start the Time Source producer application pointing to ticktock topic in Kafka

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

Step 5 - Start the Log Sink consumer application pointing to ticktock topic in Kafka

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

Step 6 - Verify ticktock output in the log-sink logs
Stream Applications and Spring Cloud Data Flow (**)

Artifact Type

Stable Release

Snapshot Release

RabbitMQ + Maven

https://dataflow.spring.io/rabbit-maven-latest

https://dataflow.spring.io/Fahreneheit-BUILD-SNAPSHOT-stream-applications-rabbit-maven

RabbitMQ + Docker

https://dataflow.spring.io/rabbit-docker-latest

https://dataflow.spring.io/Fahrenheit-BUILD-SNAPSHOT-stream-applications-rabbit-docker

Apache Kafka + Maven

https://dataflow.spring.io/kafka-maven-latest

https://dataflow.spring.io/Fahrenheit-BUILD-SNAPSHOT-stream-applications-kafka-maven

Apache Kafka + Docker

https://dataflow.spring.io/kafka-docker-latest

https://dataflow.spring.io/Fahrenheit-BUILD-SNAPSHOT-stream-applications-kafka-docker

(**) find out how to use the app-starters in Spring Cloud Data Flow by reviewing the app-registration section in the reference guide
HTTP Repository Location for Apps

Versions: Boot / Stream

Rabbit MQ

Apache Kafka

Spring Boot 2.3.x / Spring Cloud Stream 3.0.x

Stable Release / Latest Snapshot

Stable Release / Latest Snapshot
Related Projects

Spring Cloud Stream

Spring Cloud Data Flow

Spring Cloud Task

Spring Initializr
Quickstart Your Project
Bootstrap your application with Spring Initializr.

评论
添加红包

请填写红包祝福语或标题

红包个数最小为10个

红包金额最低5元

当前余额3.43前往充值 >
需支付:10.00
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明:

1.余额是钱包充值的虚拟货币,按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载,可以购买VIP、付费专栏及课程。

余额充值