2024Java程序员招聘你发现了么?
很多招聘要求多了一个叫Kafka的技术。
那么Kafka都有哪些强项呢?
1:高吞吐,低延迟:kafka每秒可以处理几十万条消息,它的延迟最低只有几毫秒,即使存储了TB级的消息它也能保持稳定的性能 2:分布式系统:kafka集群支持热扩展(无需停机就可扩展机器)
3:高并发:单节点支持数千个客户端同时读写
4:可靠性:kafka是分布式,分区,复制和容错的,消息被持久化到本地磁盘,并且支持数据备份防止数据丢失
5:多种客户端语言:Kafka支持Java、Python、.NET等语言
。。。我就不在此列举了,直接上视频吧!
![](http://tiebapic.baidu.com/forum/w%3D580/sign=5ed8bdf005166d223877159c76230945/bae70cd8bc3eb13538d98d80e01ea8d3fc1f44df.jpg?tbpicau=2024-09-18-05_1890e81079f9c51aedcb413036d53992)
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 手动重置Kafka偏移量offset
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开发接收消息监听器
很多招聘要求多了一个叫Kafka的技术。
那么Kafka都有哪些强项呢?
1:高吞吐,低延迟:kafka每秒可以处理几十万条消息,它的延迟最低只有几毫秒,即使存储了TB级的消息它也能保持稳定的性能 2:分布式系统:kafka集群支持热扩展(无需停机就可扩展机器)
3:高并发:单节点支持数千个客户端同时读写
4:可靠性:kafka是分布式,分区,复制和容错的,消息被持久化到本地磁盘,并且支持数据备份防止数据丢失
5:多种客户端语言:Kafka支持Java、Python、.NET等语言
。。。我就不在此列举了,直接上视频吧!
![](http://tiebapic.baidu.com/forum/w%3D580/sign=5ed8bdf005166d223877159c76230945/bae70cd8bc3eb13538d98d80e01ea8d3fc1f44df.jpg?tbpicau=2024-09-18-05_1890e81079f9c51aedcb413036d53992)
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 手动重置Kafka偏移量offset
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开发接收消息监听器