課程簡介

介绍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构建事件驱动的微服务

总结和结论

最低要求

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

受眾

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

人數


每位參與者的報價

客戶評論 (5)

Provisional Upcoming Courses (Require 5+ participants)

課程分類