利用阿帕奇卡夫卡、春靴、多克、库伯涅茨、PostgreSQL、开放API、春季启动启动器和AI援助开发,建立现实世界、事件驱动的微观服务。
课程的设计是让你从卡夫卡的基本面一直到建筑、测试、保安、监测、集装箱化和部署生产式的卡夫加微服务。
首先,你们将学习阿帕奇卡夫卡的核心概念,包括主题、分区、生产者、消费者、抵消、消费团体、经纪人、复制、领导人选举、伊斯兰社会党和保留。
然后,你们将着手实践发展,利用Spring Boot和Sprew Kafka建立完整的图书馆活动制作人和图书馆活动消费者微观服务。
使用现代的人工智能辅助编码工作流程, 如 GitHub 联合试点、 以产品规格为驱动开发、 PRD 文件、 实施计划、 AGENTS 等。
md和可再使用编码技能,以更有效和更一致地建立应用软件。
到课程结束时,你将建成一个完整的Kafka基于Kafka的微服务系统,其中包括REST APIs、Kafko生产者和消费者流动、PostgreSQL持久性、错误处理、重写、恢复等
战略、交易、健康检查、多克图像和Kubernetes部署。
欢迎参加这次实践课程, 介绍利用Spring Boot、Docker、Kubernetes和AI协助开发建立由事件驱动的Kafka微服务。
并逐步建立全真实世界微服务应用。
首先,你们将学习卡夫卡核心概念,如主题、分割区、生产者、消费者、抵消、消费群体、经纪人、复制品、领导人选举和保留政策。
将建立图书馆活动制作人与图书馆活动消费者应用程式,
生产者服务将披露REST APIs,并将活动公布给Kafka,消费者服务则会利用这些活动、处理它们并持续将数据输入PostgreSQL数据库。
课程还引入了现代软件建设方法,使用AI辅助开发。 我们将利用PRD文件、实施计划、GitHub Copilot、AGENTS等理念。
以更有条理和更具生产力的方式指导发展的可再利用的人工智能技能。
随着我们的进展,我们将涵盖重要的现实世界工程专题,如单位测试、集成测试、内嵌的卡夫卡测试、斯瓦格/开放API文件、生产者可靠性、消费者再加工和恢复等。
死亡信题、卡夫卡交易、完全一样的语义学、健康检查、监测、多克集装箱化和库伯涅茨部署。
到课程结束时,你将从零开始建立完整的生产式Kafka微型服务系统,并赢得设计、开发、测试、监测、包装、集装箱化和部署的信心
以 Kafka 为基础的应用程序在现实世界中。 按课程开始的科快速细分, 全面了解课程的内容。 理解课程的主要目标和学习结果 。
确定对所涉工具、技术和实际操作项目的适当期望。
开始从卡夫卡开始,了解阿帕奇卡夫加是什么以及为什么它在现代应用中被广泛使用。学习卡夫克如何适应事件驱动的建筑和微观服务。
探索卡夫卡核心术语,如主题、分割区、经纪人、生产商、消费者和客户API。 在着手开展卡夫克人实践开发之前,先构建一个强有力的概念基础。
Docker 安裝 Docker 在您的本地机器上安裝 Decker 。 理解为什么 Dockker 在当地运行 Kafka 和支持服务有用 。 为课程中的实践部分准备您开发的环境 。
已经安装了多克的学习者可以快速校验他们的设置并前进。 Kafka 组件和内存了解卡夫卡主题和分区是如何组织数据以进行缩放的 。
使用 KRaft 设置本地 Kafka , 并理解 Kafka 没有 ZooDescriptioner 是如何工作的。 创建主题并利用 Kafca CLI 命令生成/ 解密信件。 了解消息键如何影响分区选择和排序 。
探索卡夫卡生产者和消费者如何在引擎盖下工作。 了解消费抵消、消费群体、再平衡、承诺原木和保留政策。
建立当地多经纪人卡夫卡集群,了解复制、领导人选举、ISR和过失容忍度。
了解课程中将建立的生产者和消费者微服务。请看REST APIs、Kafka、PostgreSQL和Spring Boot是如何结合的。
AI-Driven Disign and Agentic Engineering理解软件开发如何随着AI编码助理而变化。
了解感应编码和代理工程之间的区别。探索AI如何帮助规划、编码、测试和文件记录。
使用AI协助的工作流程来加快应用程序的构建速度, 同时仍然理解基本概念。 本地设置: IDE 安装和配置 IntelliJIDEA。 为春季布景和卡夫卡开发准备 IDE 。
建立建设生产者和消费者服务所需的发展环境。 确保本地机器准备好实际编码。
建立图书馆事件 Kafka 制作人微服务 为生产服务创建基础春季启动项目。 设置 GitHub 联合试点, 开发过程中使用 AI 辅助编码 。
在写入代码前创建 PRD 和实施计划文件。 构建图书馆事件域模式。 创建 REST 端点以发布事件给 Kafka。 使用 KafkaTemplate 将信息发送到 Kafca 。
学习 KafkaTemplate 内部、 批发、 缓冲、 线型和自动配置。 配置序列器、 Spring Pifications、 自定义错误处理以及同步发布信件 。
单位和集成测试——图书馆活动制作人API了解单元测试与集成检测之间的区别。
构建整合测试以验证全制片人 API 流程。 通过模拟 KafkaTemplate 测试图书馆 Event 生成器组件 。
通过验证控制器、服务和卡夫卡出版行为来提高生产者对生产服务的信心。 以 Swager/ OpenAPI 3 记录REST APIs 和 Swanger / O开放API 2 来记录 REST ATI , 理解为什么开放APIP对于现代REST APS很重要。
向图书馆活动制作人添加 Swagger/ OpenAPI 支持。自动生成交互式 API 文件。使 APIS 更容易测试、理解和共享。 AGENTS 。
学会AGENTS是什么,如何指导AI编码代理人。了解技能如何帮助AI代理者一贯地执行重点任务。
创建可重复使用的单位测试和集成测试技能; 创建控制器技能,以指导持续生成REST控制器。 使用AI指令来提高代码质量并减少重复提示 。
建立图书馆活动 Kafka消费者微观服务局,重新审视消费架构和PRD文件。为消费者服务创建基础春季启动项目。构建结构化实施计划。
使用 @ KafkaListener. pol, 读取并记录即将到来的图书馆事件消息。 将原始 JSON 降序为结构化的 DTOs, 比较字符串解密器和 JsonDestriericer 。
了解Spring Kafka消费者内部和自动配置。消费者团体和消费者偏好管理学会Kafka消费者群体如何促成平行处理。
了解消费者群体通过实践实例重新平衡的思路。 在 Spring Kafka 探索默认抵消管理方式。 学习人工抵消管理如何对信件处理进行更大的控制 。
配置同时出现的消费者, 以改善传输量和可缩放性。 在数据库中保存图书馆事件, 在库中设置 PostgreSQL 的 PasgresSQ L 客户应用程序。 整合 Flyway 用于数据库系统迁移 。
创建用于图书馆事件和图书数据的实体类。 构建 Spring Data JPA 库。 应用商业逻辑来持续使用已消耗的 Kafka 信息 。
测试从生产者到卡夫卡的完整流动,到消费者到数据库。使用嵌入式卡夫加进行整合测试,了解如何嵌入型卡夫ka帮助检测卡夫克消费者。为图书馆活动消费者编写整合测试。
校验信件的消耗和处理是否正确。 测试 Kafka 行为而不取决于外部 Kafca 群集 。
创建 CRUD 端点以显示图书馆事件和图书数据构建 REST APIs 来管理书籍数据。 为消费者服务启用交换文档。 创建取端点获取图书馆活动数据 。
通过“再生”API来挖掘卡夫卡数据,完成消费者服务,同时进行加法卡处理和获得API。
Kafka制片人-例外和错误处理 了解生产者如何承认信息对耐久的影响。学习反正复制与微量辛辛辛基复制是如何共同工作的。
配置重试和重新尝试逆向故障的后退。 了解无能力生产者如何防止重复生成信息。 理解 最大. in. flyply. requests. per. connection 及其对订购的影响 。
探索生产者超时配置。 应用推荐的生产商设置来进行可靠的生产级卡夫卡应用程序。 在同步和同步生产者流动中处理错误 。
Kafka消费者-例外和错误处理 为 Kafka 消费者创建一个完整的错误处理计划。 当出现例外情况时, 探索当前的消费者行为 。 理解 Spring Kafca 在引擎盖下处理错误 。
配置带有指数后退的默认错误操作器。 使用重试听器观察尝试。 可重新处理不可复制和无法复制的例外。 向死信主题发布记录失败 。
数据库中存在永久故障记录。 通过向DLT发布和保存故障细节实施混合回收。 更新整合测试以验证再试验和恢复行为。
Kafka消费者时间配置理解中介方的时间设置。 学习影响输送量和延缓度的接货相关配置 。
探索稳定的消费者- 经纪人沟通的连接配置。 理解心跳、 会话超时、 民意调查间隔和取回环境如何影响消费者行为 。
学习如何调和消费者使用真实世界的卡夫卡应用程序。 卡夫卡交易 — — 完全可以理解卡夫克交易,也可以完全了解其语义。
学习交易如何帮助避免重复和部分信息发布。 使用 @ transactional 执行交易行为。 将多个信息作为原子交易发布 。
使用 KafkaTemplate. executeIntransAction () 来处理方案交易。 更新整合测试以验证交易行为 。 了解交易如何适用于 Kafka 消费者 。
Kafka 健康检查和监测使用春季启动器启动器的启动器学习春季启动程序启动器的基本原理。在图书馆活动制作人中启用健康检查。配置 Kafka 准备状态的健康指标。
了解准备状态检查如何帮助检测卡夫卡连接问题。 启用健康检查和卡夫克为消费者服务做好准备。 准备生产型监测申请。
软件包“ 应用程序” 作为可执行 JARs 构建生产者服务作为可执行的 JAR。 在 IDE 之外运行生产商。 传递环境变量来配置应用程序 。
构建并运行消费者服务, 作为可执行的 JAR。 学习如何独立运行 Spring Boot Kafka 应用程序 。
集装箱入门——利用多克建造和运行集装箱,了解什么是集装箱及其为何重要。学习多克基本知识,如图像、容器、多克文件以及运行时间等。
为库事件制作者创建 docker 图像。 作为 Docker 容器运行制片人。 使用不同的环境配置运行相同的 Dockker 映像。 向 Docker Hus 发布 Dockers 图像 。
构建并运行图书馆活动消费者作为 Docker 容器。 在 Kubernetes 上运行春季启动程序, 理解为什么需要在 Docker 之外使用Kubernets。 学习 Kubernets 核心概念和架构 。
使用 Minikube 在当地设置 Kubernetes。 安装和配置 kubectl。 用部署和 Pods 安装应用程序。 使用服务、 端点转发和 Ingress 来解释应用终端点 。
将应用程序缩放为多个复制软件。 使用配置地图外化配置, 配置现场和准备状态检查。 向库伯涅茨部署图书馆活动消费者。
使用 Kubernetes 秘密来安全管理敏感配置 。
最终取走最后的外卖 课程结束时 你将已经建造了完整的生产型卡夫卡微型服务系统 使用Spring Boot, Apache Kafka, PostgreSQL, Docker, Kubernetes, OpenAPI, 启动器和AI协助
发展
不仅在理论上学习Kafka概念, 你还会通过建立真正的生产者和消费者微观服务、测试、处理故障、监测健康、包装、集装箱化来应用这些概念。
把他们部署到库伯涅茨
课程为您提供了一条完整的实践路径, 从卡夫卡基本原理到建设真实世界, 由AI援助的卡夫ka微服务系统, 这些系统可靠、可测试、可观测和可以部署。
通过完成这一课程,你将能够:了解阿帕奇卡夫卡建筑和核心内部结构。
解释话题、分区、经纪人、生产者、消费者、抵消、消费群体、复制和领导选举。 用“春靴”建立卡夫卡生产商和消费者微观服务。
使用 KafkaTemplate 向 Kafka 发布事件。 请使用 @ Kafkar 听者来消耗和处理 Kafka 信息。 与信件密钥、 分区、 序列器和解导器一起工作 。
管理消费者群体, 抵消承诺, 重新平衡和同时出现的消费者。 坚持使用 Spring Data JPA将 Kafka 信息输入 PostgreSQL 。 使用 Flyway 管理数据库的系统变化 。
写作单位测试、集成测试、嵌入式卡夫卡测试和端到端测试。文档中使用 Swagger 和 OpenAPI 的REST APIs 。应用 GitHub COpilot、 PRDs、 实施计划、 AGENTS 应用 AI 辅助开发 。
配置可靠的卡夫卡生产商,使用累进、确认、一时空能、超时和建议的生产者环境。
使用回溯、指数反转、死亡信题和回收策略建设具有复原力的卡夫卡消费者。 在数据库中存储失败记录并实施混合恢复模式。
理解卡夫卡消费者时间配置以及它们如何影响真实世界应用。 执行卡夫加交易和完全正统的语义学 。
使用 Spring Boot 启动器和 Kafka 准备检查来监控生产者和消费者服务。 将 Spray Boot 应用程序包成可执行的 JAR 文件, 为 Sprew Boot Kafka 应用程序构建 Docker 图像 。
运行作为集装箱的生产者和消费者服务。 向 Docker 枢纽发布 Docker 图像。 在Kubernetes 部署 Spring Boot Kafka 应用程序 。
使用库伯涅茨部署、波兹、服务、入侵、配置地图、准备/生命探测和秘密。
最后目标:完成这一课程后,你将具备设计、建造、测试、监测、集装箱化和部署生产型Kafka微服务的技能,利用Spring Boot、Docker、Kubernetes和
AI型援助开发。