大家好我是陈师傅（假装很熟），今天咱们要干件大事——给程序世界建个"顺丰中转站"。不过这个中转站不送实体包裹（毕竟咱们头发已经够少了），专送程序之间的消息包裹！准备好了吗？带好你的咖啡和降压药（别问为什么），咱们这就开整！

---

一、"快递公司"开业前的灵魂三问

在开搞之前（敲黑板！），咱们得先搞明白三个哲学问题：

1. 到底需不需要这个快递站？

当你的系统开始出现以下症状：订单系统和物流系统天天吵架（耦合）、秒杀活动时通知消息集体堵车（吞吐瓶颈）、某些服务动不动就玩消失（单点故障）...这时候就该考虑请出我们的主角——Kafka了！

2. 要准备多大的仓库？

举个栗子🌰：假设你每天要处理100万条订单消息（别慌这只是假设），每条消息平均1KB的话：

```

100万 × 1KB × 3副本 × 7天留存 = 21GB × 7 ≈ 150GB

这时候配个200G硬盘绝对能让你睡个好觉（当然记得留20%缓冲空间）

3. 需要雇多少快递小哥？

这里有个万能公式：

推荐Broker数量 = max(副本数, CPU核心数/2, 磁盘数)

翻译成人话就是：3副本集群配3台服务器刚刚好！

二、"物流基地"施工说明书

Step1：基础建材采购

```bash

下载安装包的正确姿势（拒绝龟速）

wget --no-check-certificate https://archive.apache.org/dist/kafka/3.3.1/kafka_2.13-3.3.1.tgz

解压时的仪式感不能少

tar -zxvf kafka_2.13-3.3.1.tgz && cd kafka_2.13-3.13.1

```

Step2："调度中心"ZooKeeper搭建

ZooKeeper相当于我们的调度主管（就是那个拿着对讲机满场跑的暴躁老哥）。修改配置就像给他写工作手册：

```properties

config/zookeeper.properties

dataDir=/var/lib/zookeeper

他的记事本位置

clientPort=2181

对讲机频道号

maxClientCnxns=100

最多同时接100个电话

Step3："快递站点"Broker配置

每个Broker都是勤勤恳恳的快递小哥：

config/server.properties

broker.id=1

工号牌必须唯一！

listeners=PLAINTEXT://:9092

接单窗口号

log.dirs=/data/kafka-logs

包裹暂存区位置

num.network.threads=8

同时搬8个箱子不手抖

num.io.threads=16

拆包裹速度x16倍速

zookeeper.connect=zk1:2181,zk2:2181,zk3:2181

主管们的联系方式

三、"物流系统"压力测试指南

是骡子是马得拉出来遛遛！上压测三件套：

Case1：吞吐量测试（看看最大运力）

Producer压力测试（看能收多少包裹）

kafka-producer-perf-test.sh --topic test --num-records 1000000 --record-size 1024 --throughput -1 --producer-props bootstrap.servers=localhost:9092

Consumer压力测试（看能派多少件）

kafka-consumer-perf-test.sh --topic test --messages 1000000 --broker-list localhost:9092

Case2：容灾演练（拔网线模拟翻车）

突然停掉一个Broker后观察：

- Leader选举是否自动完成（调度主管是否靠谱）

- Consumer能否继续消费（客户会不会投诉）

四、老司机の避坑宝典

🚨坑点一：客户端连不上服务器

症状："Connection refused"疯狂刷屏

解药：

Linux版体检套餐：

ss -tulnp | grep 9092

检查端口状态

iptables -L -n

看看防火墙是不是在搞事情

Windows同学请掏出CMD：

telnet your_server_ip 9092

>连通失败就准备哭吧<

🚨坑点二：磁盘突然爆满

预防措施：

log.retention.hours=168

7天自动清理旧包裹

log.segment.bytes=1073741824

单个包裹袋不超过1GB

🚨坑点三：ZooKeeper突然宕机

应急预案：

Zookeeper集群保命三连

echo stat | nc zk1 2181

查看节点状态

echo kill | nc zk1 2181

[危险动作！仅供测试]

JMX监控走起

提前发现异常指标波动

【知识点外挂】为什么说Kafka是消息界的扛把子？

举个真实案例🌰：某电商大促时...

- 传统MQ："亲您的订单正在排队..." (队列塞满直接摆烂)

- 卡夫卡模式："已开启128条快速通道！历史订单存云端！新订单走VIP通道！"

这得益于它的三大绝技：

1. 分区存储：把Topic拆成多个partition（相当于快递柜的格子间）

2. 顺序写入：像超市货架一样码放数据包（机械硬盘也能起飞）

3. 零拷贝技术：数据包不用拆箱直接转运（省去两次内存拷贝）

最后送大家一句至理名言："纸上得来终觉浅，绝知此事要Ctrl+C/V"。不过说真的——所有配置文件我已经打包好放在GitHub了（评论区自取），但强烈建议手敲一遍体验完整流程！

下期预告：《当Kafka遇到云原生：如何在K8s上打造弹性消息中台》...想看的同学请把"想要"打在评论区！

TAG:kafka服务器搭建,kafka服务器配置,kafka启动服务,kafka 服务端