课程大纲

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 ACLs

Kafka与其他系统的集成

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

总结与下一步

要求

  • 具备核心Java编程知识
  • 了解分布式系统和消息系统的基础知识
  • 熟悉Maven或Gradle等软件开发工具

目标受众

  • 希望将Kafka集成到应用中的Java开发者
  • 从事事件驱动架构工作的软件工程师
  • 有兴趣学习Kafka作为分布式消息系统的开发者
 14 小时

客户评论 (5)

即将举行的公开课程

课程分类