部署Kafka需要先安装和配置Zookeeper。Zookeeper是一个开源的分布式协调服务,Kafka使用Zookeeper来存储元数据和协调集群中的各个节点。Kafka依赖于Zookeeper来管理和维护其集群状态信息,包括主题(topics)、分区(partitions)和消费者组(consumer groups)等。因此,在部署Kafka之前,需要先安装、配置和启动Zookeeper
###
# kafka-xx-yy
xx是scala版本,yy是kafka版本 (scala是基于jdk开发的所以需要安装jdk环境)
kafka下载地址:https://kafka.apache.org/downloads
这里我们使用kafka_2.13-2.8.0版本 可以直接去我的百度网盘下载:
链接: https://pan.baidu.com/s/1wvY4G7AuCNEszIhgkNnY-Q 提取码: x26h
###
# zookeeper
###
Apache软件基金会的一个软件项目,它为大型分布式计算提供开源的分布式配置服务、同步服务和命名注册
链接: https://pan.baidu.com/s/1lVFgSNxU0RPtpGe5AFZ5Ug 提取码: 8sjj
###
# jdk1.8
###
链接: https://pan.baidu.com/s/1ish5N6XJ9XOoX7xoErrI-Q 提取码: b53h
###
# 安装jdk1.8
![](https://img.kancloud.cn/dc/82/dc82620d4f1ff1e5c276a5b33637090d_806x667.png)
###
查看安装情况 `java -version`
###
# 安装zookeeper
###
上传解压就不废话了
###
![](https://img.kancloud.cn/24/c8/24c86fa20c24ce2faab0a75ce716b1f4_919x372.png)
###
zookeeper默认端口号是2181 关闭防火墙或者阿里云开放该端口号
###
启动zk 在bin目录里面有启动文件 `./bin/zkServer.sh start`
###
# 安装kafka
###
上传解压就不废话了
###
![](https://img.kancloud.cn/19/5e/195efa1f3b40b76810fe99cfaeae5611_1507x876.png)
###
![](https://img.kancloud.cn/1c/9b/1c9b2a725f2997f5878e6dc42a21cc27_1231x363.png)
###
bin目录启动kafka
###
`./kafka-server-start.sh ../config/server.properties &`
###
bin目录停止kafka
`./kafka-server-stop.sh`
###
这种启动方式如果直接启动信息会打印在控制台如果关闭窗口,kafka随之关闭
###
所以我们可以守护进程方式启动
###
`./kafka-server-start.sh -daemon ../config/server.properties &`
###
- 前言介绍
- 什么是MQ消息中间件和应用场景
- 对比当下主流消息队列和选择
- kafka的快速认知和核心概念
- 部署安装Zookeeper和Kafka
- kafka命令行初步创建topic查看topic
- kafka命令行生产消费消息实战
- kafka命令行删除topic和查看broker节点信息
- kafka命令行点对点和发布订阅模型理论
- kafka命令行消费组配置实现点对点消费
- kafka命令行消费组配置实现订阅消费
- kafka当中数据存储流程原理概述LEO+HW等的讲解
- Springboot2.x整合kafka客户端+创建topic
- Springboot2.x列举/删除/详情/增加topic
- kafka生产者原理详解
- Springboot2.x实现消息发送(对key进行hash方案)
- 恶补ProducerRecord和key的作用
- Springboot2.x实现消息发送回调函数(对key进行hash方案)
- Springboot2.x实现消息发送(指定分区发送消息方案)
- Springboot2.x实现生产者根据自定义策略到指定分区
- Kafka的Consumer消费者机制和分区策略讲解
- Kafka当中Consumer消费者重新分配策略和offset维护机制
- Springboot2.x实现消费消息实战
- kafka当中如何实现消费者重头消费
- kafka当中手工提交offset
- kafka数据文件存储和log日志讲解
- 分布式应用核心CAP理论讲解
- kafka可靠性保障理论讲解(Replica+Ack)(上)
- kafka可靠性保障理论讲解(Replica+Ack)(下)
- kafka当中HighWatermark的作用
- kafka高可用集群之zookeeper集群搭建实战
- kafka高可用集群之kafkaf集群搭建实战
- Springboot2.x实现链接kafka创建查看topic实战
- Springboot2.x实现kafka生产发送消息实战
- kafka当中日志数据清理理论讲解
- Kafka高性能原理分析
- Springboot2.x整合spring-kafka并实现发送消息实战
- Springboot2.x整合spring-kafka并实现消费消息实战
- Springboot2.x整合spring-kafka并实现事务消息实战
- 大总结