VIP20

本课程属于：035-任务调度平台OpenAPI契约落地 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

任务调度平台OpenAPI与Kafka事件驱动集成

共计 30 章节

点击此处阅读海量试读课程：100+行业、1000+细分领域

课程导学与整体架构

任务调度平台演进史 · OpenAPI与事件驱动概念 · Kafka在调度中的角色

课程导学整体架构

任务调度平台核心模型

任务(Task) · 作业(Job) · 工作流(Workflow)

任务调度平台核心…Task

OpenAPI基础与RESTful设计

RESTful API设计原则 · 资源命名规范 · HTTP方法语义

任务调度平台OpenAPI规范设计

任务CRUD API · 作业提交API · 工作流定义API

OpenAPI任务调度平台

API安全与认证机制

API Key · JWT Token · OAuth2.0集成

API文档与SDK生成

OpenAPI 3.0规范编写 · Swagger UI集成 · 使用OpenAPI Generato…

Kafka核心概念与架构

Topic · Partition · Producer

Kafka核心概念

Kafka集群部署与配置

单机与集群部署 · 关键配置参数(acks · retries

Kafka集群部署

Kafka生产者(Producer)深入

发送模式(sync/async) · 分区策略 · 幂等性与事务

Kafka消费者(Consumer)深入

消费组与再均衡 · 偏移量提交(自动/手动) · 消息顺序保证

Kafka Topic设计与分区策略

分区数选择原则 · 键(Key)与分区映射 · 日志压缩(Log Compactio…

Kafka Connect与Schema Registry

Source/Sink Connec… · Avro/Protobuf Sche… · Schema演化兼容性

事件驱动架构模式

事件通知 · 事件溯源 · CQRS

事件驱动架构模式事件通知

任务调度事件模型设计

任务创建事件 · 任务状态变更事件 · 作业完成事件

任务调度事件模型…任务创建事件

OpenAPI与Kafka集成模式

API同步触发Kafka消息 · API异步返回事件ID · Webhook回调

任务提交与事件发布流程

用户通过API提交任务 -> 服务端…

任务提交事件发布流程

任务状态变更事件消费

消费者监听TaskStatusCha…

任务状态变更事件…TaskStatusCh…

工作流引擎与事件驱动

DAG工作流定义 · 节点状态事件驱动下一个节点执行 · 并行与条件分支的事件处理

工作流引擎事件驱动

超时与重试机制的事件化

任务超时事件发布 -> 重试策略判断…

超时重试机制的事件化

事件驱动的任务调度器实现

基于Kafka的延迟队列 · 时间轮(Timing Wheel) · 优先级队列与事件调度

事件驱动的任务调…Kafka

API与Kafka的幂等性设计

API幂等键(Idempotency… · Kafka生产者幂等性 · 消费者去重(幂等消费者)

事务性消息与Exactly-Once语义

Kafka事务API · 原子写入多个分区 · 事务协调器

Exactly-Once事务性消息

事件溯源与任务审计日志

使用Kafka存储任务状态变更历史 · 事件回放(Replay) · 审计追踪与合规

事件溯源任务审计日志

OpenAPI与Kafka的监控与可观测性

API请求追踪(OpenTeleme… · Kafka消费者Lag监控 · 事件延迟分析

高可用与容错设计

API多副本部署 · Kafka多副本与ISR · 消费者容错与重试

高可用容错设计

性能优化与压力测试

API连接池与异步IO · Kafka批量发送与压缩 · 消费者并行度调优

性能优化压力测试

实战案例一

基于OpenAPI与Kafka的定时… · API设计 · 事件流设计

实战案例一OpenAPI

实战案例二

事件驱动的分布式工作流编排平台 · 节点事件驱动 · 失败重试与补偿事务

实战案例二事件驱动的分布式…

实战案例三

实时任务监控与告警系统 · 实时聚合 · 告警规则引擎

实战案例三实时任务监控

课程总结与未来展望

架构模式总结 · 最佳实践清单 · Kafka与API演进趋势(Asyn…

课程总结未来展望