部署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

###
查看安裝情況 `java -version`
###
# 安裝zookeeper
###
上傳解壓就不廢話了
###

###
zookeeper默認端口號是2181 關閉防火墻或者阿里云開放該端口號
###
啟動zk 在bin目錄里面有啟動文件 `./bin/zkServer.sh start`
###
# 安裝kafka
###
上傳解壓就不廢話了
###

###

###
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并實現事務消息實戰
- 大總結