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

总结和结论