资源介绍
Spring Boot与Apache Kafka实战指南：从入门到项目落地 (中文字幕英文视频教程)
《Spring Boot与Apache Kafka实战指南：从入门到项目落地》是一门针对分布式消息系统与微服务架构的实战课程，旨在帮助开发者掌握Apache Kafka的核心原理及其与Spring Boot框架的深度集成。课程涵盖从基础概念到实际项目开发的全流程，通过理论讲解、环境搭建、代码实现及真实案例演示，使学员能够独立构建高吞吐、低延迟的分布式消息系统，并应用于企业级微服务架构中。
课程共包含37个视频教程（MP4格式）及配套中文字幕（SRT格式），内容分为8个模块，覆盖Kafka的安装配置、消息生产与消费、JSON序列化、真实项目开发、事件驱动架构及微服务实践。所有视频均提供详细操作步骤与代码示例，适合Java开发者、系统架构师及对分布式系统感兴趣的从业者。
二、课程模块详解
1. 模块一：Apache Kafka基础入门
本模块通过2个视频教程，系统讲解Kafka的核心概念与架构设计：
视频1：Apache Kafka概述
介绍Kafka的起源、应用场景（如日志收集、指标监控、流处理）及其作为分布式流平台的优势，包括高吞吐、持久化存储、横向扩展等特性。
视频2：Kafka核心概念
深入解析Broker、Topic、Partition、Producer、Consumer等核心组件，结合图示说明消息的发布-订阅机制与分区策略。
配套提供源码下载入口，帮助学员快速获取示例代码。
2. 模块二：Kafka环境搭建
针对不同操作系统，提供2个视频教程及Windows环境下的命令行笔记：
视频1：Mac系统安装与配置
演示通过Homebrew安装Kafka、启动Zookeeper与Broker服务，并验证基础功能。
视频2：Windows系统安装与配置（含CLI操作）
详细讲解解压安装包、修改配置文件（server.properties）、启动服务及创建Topic的完整流程，附kafka_commands_windows_notes.txt记录常用命令。
此模块确保学员能够独立部署Kafka环境，为后续开发奠定基础。
3. 模块三：Spring Boot集成Kafka实现字符串消息通信
本模块通过7个视频教程，实现Spring Boot项目与Kafka的字符串消息交互：
视频1-2：Spring Boot项目创建与Kafka配置
使用IntelliJ IDEA创建项目，集成spring-kafka依赖，配置Producer与Consumer的bootstrap-servers、key-serializer等参数。
视频3-4：Topic创建与消息生产
通过KafkaTemplate发送字符串消息至指定Topic，演示同步与异步发送模式。
视频5-6：REST API开发与消息消费
构建Controller接口接收HTTP请求，触发消息生产；使用@KafkaListener注解实现消费者逻辑，打印接收到的消息。
配套提供项目源码包（springboot-kafka-tutorial.zip），含完整代码与配置文件。
4. 模块四：Spring Boot集成Kafka实现JSON消息通信
本模块升级消息格式为JSON，通过8个视频教程实现序列化与反序列化：
视频1-2：JSON序列化器配置
自定义StringJsonMessageConverter，配置Producer与Consumer的value-serializer与value-deserializer为JSON类型。
视频3-4：POJO类设计与消息生产
创建Order等实体类，通过KafkaTemplate发送JSON格式消息，验证序列化结果。
视频5-6：REST API与消费者实现
开发接口接收JSON请求体，消费者端反序列化为POJO对象并处理业务逻辑。
视频7：代码优化
将Topic名称等硬编码参数提取至application.properties，通过@Value注解动态注入。
配套提供优化后的项目源码包，强化代码可维护性。
5. 模块五：真实项目—Wikimedia数据实时采集
本模块通过7个视频教程，构建Wikimedia编辑事件的生产者服务：
视频1-2：项目架构设计与微服务拆分
规划“Wikimedia生产者”与“数据库消费者”两个微服务，明确职责边界。
视频3-5：Wikimedia事件监听与消息生产
集成Wikimedia API，监听编辑事件（如页面创建、修改），通过Kafka发送至wikimedia.edits Topic。
视频6：项目演示
运行生产者服务，验证消息实时发送与Kafka集群接收。
配套提供项目源码包（springboot-kafka-real-world-project.zip），含完整事件处理逻辑。
6. 模块六：真实项目—MySQL数据持久化
本模块通过7个视频教程，实现Kafka消费者将数据写入MySQL：
视频1-3：消费者服务配置与实现
创建@KafkaListener方法，接收wikimedia.edits消息并解析为Java对象。
视频4-5：MySQL集成与数据存储
配置JPA依赖，定义WikimediaData实体类与Repository接口，将消息内容持久化至数据库。
视频6：代码优化
移除硬编码的数据库URL与凭据，改用配置文件管理。
配套提供完整数据库操作源码，支持学员快速复现。
7. 模块七：事件驱动架构（EDA）理论
本模块通过2个视频教程，解析EDA的核心思想与优势：
视频1：EDA定义与组件
对比请求-响应模式，说明事件源、事件通道、事件处理器等角色。
视频2：EDA优势与应用场景
强调松耦合、可扩展性，适用于电商订单处理、物联网数据采集等场景。
8. 模块八：事件驱动微服务实战
本模块通过13个视频教程，构建包含订单、库存、邮件服务的微服务架构：
视频1-4：项目架构设计与基础服务开发
创建OrderService、StockService、EmailService及Base-Domains四个微服务，定义DTO类（如Order、OrderEvent）。
视频5-8：订单服务开发
配置Kafka生产者，创建REST API接收订单请求，发送order_created事件至orders Topic。
视频9-11：库存与邮件服务开发
库存服务监听orders Topic，扣减商品库存；邮件服务发送订单确认邮件。
视频12：系统联调与演示
同时运行三个微服务，验证事件驱动流程的正确性。
配套提供完整微服务源码包（springboot-kafka-microservices.zip），支持学员部署与测试。
三、课程特色与适用人群
实战导向：从环境搭建到项目落地，每一步均提供可运行的代码示例。
中文字幕支持：所有视频配备SRT中文字幕，降低学习门槛。
企业级场景覆盖：包含日志采集、订单处理、数据持久化等真实业务场景。
架构思维培养：通过EDA与微服务模块，提升系统设计能力。
适用人群：
Java开发者希望掌握分布式消息系统
系统架构师规划高可用微服务架构
高校学生补充分布式计算实践经验
四、学习收获
完成本课程后，学员将能够：
独立部署与配置Kafka集群
使用Spring Boot开发Kafka生产者与消费者
实现JSON消息的序列化与反序列化
构建事件驱动的微服务架构
解决消息丢失、重复消费等常见问题
课程通过37个视频教程、源码包及详细文档，为学员提供一站式学习体验，助力其在分布式系统领域快速成长。