Kafka Fundamentals for Java Developers

• 對核心Java編程的理解
• 對分佈式系統和消息系統的基本了解
• 熟悉Maven或Gradle等軟件開發工具

受眾

• 希望將Kafka集成到其應用程序中的Java開發人員
• 從事事件驅動架構的軟件工程師
• 對將Kafka作為分佈式消息傳遞系統進行學習的開發人員

Kafka是一個分佈式事件流平台，用於高性能數據管道、實時分析和事件驅動的架構。

這個由講師主導的現場培訓（線上或線下）旨在幫助希望將Apache Kafka集成到他們的應用程序中以實現可靠、可擴展和高吞吐量消息傳遞的中級Java開發人員。

完成本次培訓後，學員將能夠：

• 了解Kafka的架構和核心組件。
• 設置和配置Kafka集群。
• 使用Java生成和消費消息。
• 實現Kafka Streams以進行實時數據處理。
• 確保Kafka應用程序中的容錯和可擴展性。

課程形式

• 互動講座和討論。
• 大量練習和實踐。
• 在實驗室環境中進行實踐。

課程定制選項

• 要請求本課程的定制培訓，請聯繫我們安排。

介绍Apache Kafka

• 什么是Kafka，为什么要使用它？
• 核心组件：主题、分区、生产者、消费者、 брокеры
• 了解Kafka的发布-订阅模型
• Kafka在实际应用中的用例

设置Kafka开发环境

• 安装和配置Kafka和ZooKeeper
• 用于主题管理的Kafka CLI工具
• 为高可用性配置Kafka

Kafka生产者和消费者

• 在Java中创建Kafka生产者
• 使用键、分区和确认生产消息
• 在Java中创建Kafka消费者
• 消费者组和偏移量管理

使用Kafka Streams

• Kafka Streams API简介
• 处理实时数据流
• 有状态处理与无状态处理
• 窗口、连接和聚合

确保可靠性和性能

• Kafka复制和容错
• 优化生产者和消费者配置
• 监控Kafka性能

Kafka安全性和身份验证

• 启用SSL/TLS加密
• 使用SASL配置身份验证
• 使用Kafka ACL进行基于角色的访问控制

将Kafka与其他系统集成

• 使用Kafka Connect与数据库集成
• 将Kafka连接到Elasticsearch、PostgreSQL和其他数据源
• 使用Kafka构建事件驱动的微服务

总结和结论