【Udemy中英字幕】Apache Kafka for Developers using Spring Boot[LatestEdition]

面向使用 Spring Boot 的开发人员的 Apache Kafka[最新版本]

学习使用 Spring Boot 3.x 通过 Kafka Unit/Integration 测试构建企业标准 Kafka 生产者/消费者。

讲师：Pragmatic Code School

双语IT资源独家Udemy付费课程，独家中英文字幕，配套资料齐全！

用不到1/10的价格，即可享受同样的高品质课程，且可以完全拥有，随时随地都可以任意观看和分享。

您将学到什么

• Apache Kafka 及其内部结构
• 使用 Spring Boot 构建企业标准 Kafka 客户端应用程序
• 使用 JUnit 编写单元测试
• 使用 JUnit 和嵌入式 Kafka 编写集成测试
• 使用 Kafka 生产者/消费者和 Spring Boot 构建端到端应用程序

探索相关主题

要求

• 需要 Java 11 或更高版本
• Intellij、Eclipse 或类似 IDE
• 关于 Spring Boot 的知识
• 拥有使用 JUnit 编写测试的经验
• 需要 Gradle 或 Maven 知识

描述

本课程旨在为您提供使用 SpringBoot 的 Apache Kafka 的理论和编码体验。本课程面向希望使用 SpringBoot 构建企业标准 Kafka 客户端应用程序的开发人员。

如果您期待了解下面列出的内容：

• Kafka 非常适合的用例

• Kafka 的内部结构及其工作原理

• 使用 Spring Boot 的生产者/消费者API构建企业标准Kafka 客户端应用程序

• Kafka 客户端应用程序的单元/集成测试

那么这门课程就很适合你。这是一门纯实践导向的课程，你将通过代码学习概念。

在本课程结束时，您将全面了解如何使用 SpringBoot 和生产者/消费者 API 编写和实现 Kafka 客户端。

Kafka 入门

• 在本节中，我将简要介绍 Apache Kafka、术语以及 Kafka 的不同客户端 API

下载并安装 Kafka

• 在本节中，我们将从 Kafka 网站下载 Kafka 发行版。

了解 Kafka 组件及其内部结构 – （理论 + 实践）

在本节中，我们将从理论角度探索 Kafka 内部结构，然后亲手探索 Kafka 内部结构。

• 了解 Kafka 中的主题和分区

• 设置具有多个代理的本地 Kafka 集群

• Kafka 集群中的生产者/消费者消息

• 了解消费者补偿和消费者群体

• 提交日志和保留策略

• 了解 Kafka 负载分布、容错和稳健性

应用概述

• 本节介绍我们将在本课程中构建的应用程序。

构建 SpringBoot Kafka Producer – 实践

在本节中，我们将学习如何使用 Spring Boot 构建 Kafka Producer。

• 构建 RestAPI，通过该 API 可以将事件从外部发布到应用程序中

• 探索KafkaTemplate将数据发布到Kafka Topic中

• 了解将消息生成到 Kafka 的不同方法

• 学习使用 Headers 发布 Kafka 记录

使用 JUnit5 进行集成测试 – 实践

在本节中，我们将了解使用嵌入式 Kafka 编写集成测试的不同方法。

• 编写集成测试用例以使用JUnit5与API交互

• 编写集成测试用例以使用JUnit5与嵌入式 Kafka 进行交互

使用 JUnit5 进行单元测试 – 动手实践

在本节中，我们将学习编写 Kafka Producer 单元测试的不同方法。

• 使用@WebMVC注释和MockMVC将单元测试写入控制器层

• 将验证添加到端点中的请求负载中

• 为不同的响应代码编写自定义错误处理程序

Kafka Producer – 使用密钥发送消息 – 实践

在本节中，我们将学习如何使用 Key 将记录发送到 Kafka Topic。

Kafka Producer – 重要配置

在本节中，我们将了解向 Kafka 可靠传递消息时需要考虑的不同关键配置

构建 SpringBoot Kafka Consumer – 动手实践

在本节中，我们将学习如何使用 Spring Boot 构建 Kafka Consumer。

• 设置基础消费者项目 library-events 消费者

• 了解配置 Kafka Consumer 所需的不同 Spring Kafka 术语

• 了解如何使用@KafkListener注释配置 Kafka 消费者

• 了解“Spring Boot Auto Configuration 如何在 Kafka Consumer 的后台工作”

消费者群组和消费者偏移管理-实践

在本节中，我们将编码并了解消费者组和偏移管理。

• 演示消费者组在可扩展消息消费和消费者重新平衡方面如何发挥重要作用

• 了解 Kafka 的默认消费者偏移管理

• 了解如何从应用程序手动管理消费者偏移量

• 演示如何通过将并发级别提高到 1 以上来实现可扩展的消息消费

在数据库中持久保存库事件 – 使用 H2 InMemory 数据库

在本节中，我们将编写代码并学习如何使用 Spring JPA 将 DB 层集成到 library-events-consumer 中。

• 配置 H2 内存数据库

• 创建 LibraryEvent 和 Book 实体

• 构建服务层来处理 LibraryEvent – 添加事件类型

• 构建服务层来处理 LibraryEvent – MODIFY 事件类型

使用嵌入式 Kafka – Kafka Consumer 进行集成测试

在本节中，我们将编码并学习为 Kafka Consumer 编写集成测试。

• 配置嵌入式 Kafka 进行集成测试

• 编写集成测试以发布“NEW” LibraryEvent

• 编写集成测试以发布“更新” LibraryEvent

• 使用 TestContainers 对真实数据库进行集成测试

错误处理、重试和恢复 – Kafka 消费者

在本节中，我们将了解 Kafka Consumer 可用的不同错误处理技术。

• 自定义错误处理程序

• 在 Kafka 消费者中重试

• 使用自定义 RetryPolicy 重试 SpecificExceptions

• Kafka Consumer 中的恢复

• 处理 Kafka Consumer 中的恢复

错误处理、重试/恢复 – Kafka Producer

• Kafka Producer 中的错误处理

• 在 Kafka Producer 中重试 – Broker 不可用

• 在 Kafka Producer 中重试 – Min.in.sync.replicas

• 在 Kafka Producer 中保留/恢复失败的记录

到本文结束时，您将完全理解和掌握使用 Spring Boot 构建企业标准 Kafka 消费者和生产者以及使用EmbeddedKafka进行单元和集成测试的知识。

本课程适合哪些人：

• 希望使用 Apache Kafka 构建生产者/消费者的 Java/Spring 开发人员
• 任何愿意了解 Apache Kafka 并使用 SpringBoot 实现的人