Building Stream Processing Applications with Kafka Streams

• 理解Apache Kafka
• Java编程經驗

Kafka Streams 是一個客戶端庫，用於構建應用程序和微服務，其數據在 Kafka 消息系統之間傳遞。傳統上，Apache Kafka 依賴於 Apache Spark 或 Apache Storm 來處理消息生產者和消費者之間的數據。通過在應用程序中調用 Kafka Streams API，數據可以直接在 Kafka 中進行處理，從而避免了將數據發送到單獨的集群進行處理的需求。

在這場由講師指導的線下培訓中，參與者將學習如何將 Kafka Streams 集成到一組示例 Java 應用程序中，這些應用程序在 Apache Kafka 之間傳遞數據以進行流處理。

在培訓結束時，參與者將能夠：

• 了解 Kafka Streams 的功能及其相較於其他流處理框架的優勢
• 直接在 Kafka 集群中處理流數據
• 編寫與 Kafka 和 Kafka Streams 集成的 Java 或 Scala 應用程序或微服務
• 編寫簡潔的代碼，將輸入的 Kafka 主題轉換為輸出的 Kafka 主題
• 構建、打包並部署應用程序

目標受眾

• 開發人員

課程形式

• 部分講座、部分討論、練習和大量動手實踐

注意事項

• 如需為本課程定制培訓，請聯繫我們安排

簡介

• Kafka 與 Spark、Flink 和 Storm 的比較

Kafka Streams 功能概述

• 有狀態和無狀態處理、事件時間處理、DSL、基於事件時間的窗口操作等

案例研究：使用 Kafka Streams API 進行預算預測

設置開發環境

創建 Streams 應用程序

啟動 Kafka 集群

準備主題和輸入數據

處理流數據的選項

• 高級 Kafka Streams DSL
• 低級 Processor

轉換輸入數據

檢查輸出數據

停止 Kafka 集群

應用程序部署選項

• 經典運維工具（Puppet、Chef 和 Salt）
• Docker
• WAR 文件

故障排除

總結與結論