课程大纲

介绍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)

即将举行的公开课程

课程分类