領先一步
VMware 提供培訓和認證,助您加速進步。
瞭解更多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 輸出
透過查閱參考指南中的應用註冊部分,瞭解如何在 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.2 / Spring Cloud Stream 4.2.0 | 穩定版 / 最新快照版 | 穩定版 / 最新快照版 |