•001.课程概述 •002.What is Kafka？ •003.谁在使用Kafka •004.Kafka的起源 •005.Kafka名字的由来 •006.Kafka的发展历程 •007.Kafka版本迭代演进 •008.Kafka运行环境前置要求 •009.JDK17的下载 •010.JDK17的安装与配置 •011.Kafka的下载和安装 •012.Kafka环境启动的两种方式 •013.Kafka安装目录的介绍 •014.Zookeeper服务器的启动 •015.Kafka服务器的启动 •016.Zookeeper和Kafka服务器的关闭 •017.Zookeeper服务器的下载 •018.Zookeeper服务器的安装 •019.Zookeeper服务器的配置 •020.Zookeeper服务器的启动 •021.Zookeeper服务器与Tomcat端口冲突处理 •022.使用独立的Zookeeper启动Kafka •023.Kafka启动使用KRaft生成Cluster UUID •024.kafka-storage.sh脚本参数解读 •025.Kafka启动使用KRaft •026.自定义Cluster UUID启动Kafka •027.Docker的卸载和安装 •028.Docker的卸载和安装 •029.Docker引擎启动与关闭 •030.拉取Kafka的Docker镜像 •031.启动Kafka的Docker容器 •032.Kafka的主题Topic和事件Event •033.通过脚本工具创建主题Topic •034.kafka-topics.sh脚本工具的使用 •035.在主题Topic中写入一些事件Events •036.从主题Topic中读取事件Events •037.从主题Topic中读取事件Events •038.外部环境连接Kafka •039.外部环境连不上Kafka？ •040.Docker容器Kafka配置文件 •041.Docker容器Kafka配置文件复制到Linux •042.Docker容器Kafka配置文件修改 •043.Docker容器Kafka配置文件映射 •044.Idea之Kafka插件工具 •045.Kafka连接工具Offset Explorer •046.Kafka连接工具CMAK •047.Kafka连接工具CMAK配置与启动 •048.Kafka连接工具CMAK使用限制 •049.Kafka监控工具EFAK •050.Kafka监控工具EFAK配置 •051.Kafka监控工具EFAK部署运行 •052.Spring Boot集成Kafka开发 •053.Spring Boot集成Kafka开发配置 •054.Spring Boot集成Kafka事件Event发送 •055.Spring Boot集成Kafka事件Event发送测试 •056.Spring Boot集成Kafka事件Event读取 •057.Kafka的几个概念快速梳理 •058.SpringBoot集成Kafka读取最早的消息 •059.SpringBoot集成Kafka读取最早的消息 •060.060-手动重置Kafka偏移量offset •061.061-消息消费时偏移量策略的配置 •062.Spring Boot集成Kafka发送Message对象消息 •063.Spring Boot集成Kafka发送ProducerRecord对象消息 •064.Spring Boot集成Kafka发送指定分区的消息 •065.Spring Boot集成Kafka发送默认topic消息 •066.kafkaTemplate.send()和kafkaTemplate.sendDefault()的比较 •067.获取生产者消息发送结果 •068.阻塞式获取生产者消息发送的结果 •069.非阻塞式获取生产者消息发送的结果 •070.SpringBoot集成Kafka开发发送对象消息 •071.SpringBoot集成Kafka自动装配的KafkaTemplate •072.SpringBoot集成Kafka开发发送对象消息序列化 •073.SpringBoot集成Kafka开发发送消息的KafkaTemplate注入 •074.Kafka的核心概念Replica副本 •075.Kafka命令行脚本创建topic并指定分区和副本 •076.SpringBoot集成Kafka创建topic并指定分区和副本 •077.SpringBoot集成Kafka创建topic并指定分区和副本 •078.生产者发送消息的分区策略测试 •079.生产者发送消息的分区策略源码分析 •080.生产者发送消息的分区策略源码分析 •081.生产者发送消息的分区策略源RoundRobinPartitioner •082.生产者发送消息配置分区策略RoundRobinPartitioner •083.生产者发送消息配置分区策略RoundRobinPartitioner测试 •084.生产者发送消息自定义分区策略 •085.生产者发送消息自定义分区策略 •086.Kafka生产者发送消息的流程 •087.Kafka自定义消息发送的拦截器 •088.Kafka自定义消息发送的拦截器测试 •089.SpringBoot集成Kafka开发接收消息体内容 •090.SpringBoot集成Kafka开发接收消息头内容 •091.SpringBoot集成Kafka开发接收消息所有内容 •092.SpringBoot集成Kafka开发接收对象消息 •093.SpringBoot集成Kafka开发接收对象消息 •094.SpringBoot集成Kafka开发接收对象消息 •095.SpringBoot集成Kafka开发接收消息监听器注解 •096.SpringBoot集成Kafka开发接收消息监听器手动确认消息 •097.SpringBoot集成Kafka开发接收消息监听器 •098.SpringBoot集成Kafka开发接收消息监听器手动确认消息 •099.SpringBoot集成Kafka开发接收消息监听器