Contents
反應性Kafka域:實時數據處理應用程序的構建
課程概述
這項全面的課程是專為想要從頭開始學習反應性Kafka的經驗豐富的工程師而設計的。在課程結束時,與Kafka合作時,您將獲得高水平的舒適度和熟練程度。
課程內容
kafka基礎
- 使用個性化Docker Images以最新的Kraft模式配置Kafka
- 啟動服務器配置
-Kafka主題命令和選項 - 使用控制台的生產商和消費者
- 了解卡夫卡的特性及其影響
- 在Kafka發布和消費消息
- 序列化和應得的機制在卡夫卡
- 卡夫卡日誌保留和管理
- 抵消概念和偏移重新定義以消耗特定時間的消息
- 卡夫卡消息傳遞格式
- 使用Kafka消費者組的應用程序大小
- 保證在Kafka的消息順序
帶反應性編程的kafka
- 使用反應性編程開發Kafka在Java中的生產和消費者應用
- 探索各種生產者和消費者設置
- 抵消自動重新定義機制
- 消息確認技術
- 通過發布數百萬事件來測試性能
- 尋找特定消息的偏移
- 分區策略(合作粘性分配者和範圍分配器)
kafka群集
- 了解Kafka群集的操作
- 使用Docker組合配置Kafka群集
- 在Kafka群集中證明耐力耐受性及其對生產和消費應用的影響
最佳實踐
- 消息可靠性的生產者確認實現
- 在同步中配置最小複製品
- 創建IDEMPOTENTER生產商和消費者來處理重複消息
- 壓縮技術以減少消息傳遞大小並改善吞吐量
- 解決常見問題:確定理想數量的主題,分區和副本
- 批次處理和消息傳遞,以更好地使用CPU
- 錯誤處理策略,包括嘗試機制,無效的消息傳遞主題和中毒的藥丸消息
批次和並行處理
-
並聯有效地消費消息,維護正確的順序並使用可用的CPU
ERRO治療
- 實施嘗試處理消息中錯誤的嘗試機制
- 無效的消息傳遞主題以捕獲和處理失敗的消息
- 尖銳的藥丸消息及其在治療錯誤治療中的作用
kafka交易
-
以交易模式生成和消費消息(類似於數據庫交易)
集成測試
-
使用構建的-IN -in Kafka開發集成測試
kafka安全
- 使用簡單的憑據和SSL加密實施安全措施
您將學到什麼
- 從零學習kafka
- 春季kafka-事件 – 面向微服務
- 批次和並行處理
- 卡夫卡交易
- 編寫集成測試
-
最佳實踐
加入本課程,並在主導反應性編程技術,批處理處理,並行處理和有效的錯誤處理策略的同時,解鎖Apache Kafka的全部潛力。