Kafka 操作流程（零基础完整流程）
今天：
我们不讲复杂理论。
直接：
从：
启动 Kafka ↓ 创建 Topic ↓ 发送消息 ↓ 消费消息完整走一遍。
你学完：
至少会：
真正把 Kafka 跑起来一、Kafka 整个流程图（先建立概念）
Kafka 最核心流程：
生产者（发消息） ↓ Topic（存消息） ↓ 消费者（读消息）例如：
Go程序 ↓ 发送 "hello" ↓ Kafka保存 ↓ 另一个Go程序读取二、第一步：安装 Docker
因为：
现在：
Kafka 一般都用 Docker 跑。
先测试：
docker-v如果：
输出：
Docker version xxx说明 Docker 正常。
三、第二步：下载 Kafka 镜像
dockerpull bitnami/kafka四、什么是镜像
镜像：
你可以理解成：
Kafka 安装包五、第三步：启动 Kafka 容器（重点）
执行：
dockerrun-d\--namekafka\-p9092:9092\-eKAFKA_CFG_NODE_ID=1\-eKAFKA_CFG_PROCESS_ROLES=broker,controller\-eKAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER\-eKAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093\-eKAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092\-eKAFKA_CFG_CONTROLLER_QUORUM_VOTERS=1@localhost:9093\-eALLOW_PLAINTEXT_LISTENER=yes\bitnami/kafka六、这里到底发生了什么
Docker：
会：
创建 Kafka 容器 ↓ 启动 Kafka 服务七、查看 Kafka 是否启动成功
dockerps如果看到：
kafka说明成功。
八、9092 是什么
Kafka 默认端口：
9092以后：
Go 程序：
连接：
localhost:9092就是连接 Kafka。
九、第四步：创建 Topic（重点）
Kafka：
消息必须放进：
Topic里面。
十、Topic 是什么
Topic：
你可以理解成：
消息分类例如：
订单消息 日志消息 用户消息十一、创建 Topic
执行：
dockerexec-itkafka kafka-topics.sh\--create\--topicorder-topic\--bootstrap-server localhost:9092十二、命令详细解析
docker exec
进入容器执行命令kafka-topics.sh
Kafka Topic 管理工具。
–create
表示：
创建 Topic–topic order-topic
Topic 名字：
order-topic–bootstrap-server
连接 Kafka。
十三、查看 Topic
执行：
dockerexec-itkafka kafka-topics.sh\--list\--bootstrap-server localhost:9092十四、如果看到
order-topic说明：
Topic 创建成功。
十五、第五步：发送消息（Producer）
现在：
开始发消息。
十六、启动生产者
执行：
dockerexec-itkafka kafka-console-producer.sh\--topicorder-topic\--bootstrap-server localhost:9092十七、现在终端会卡住
这是正常的。
因为：
Kafka：
正在等待：
你输入消息十八、输入消息
例如：
hello回车。
再输入：
world十九、这些消息去哪了
Kafka：
已经：
存进 order-topic了。
二十、第六步：消费消息（Consumer）
再开一个终端。
二十一、启动消费者
执行：
dockerexec-itkafka kafka-console-consumer.sh\--topicorder-topic\--from-beginning\--bootstrap-server localhost:9092二十二、会发生什么
终端：
会打印：
hello world二十三、完整流程（重点）
你现在：
已经真正完成：
生产者 ↓ 发送消息 ↓ Kafka Topic ↓ 消费者读取这就是：
Kafka 最核心流程。
二十四、为什么生产者和消费者是两个终端
因为：
真实项目：
它们本来：
就是：
两个不同程序例如：
订单系统
负责：
发送消息库存系统
负责：
读取消息二十五、第七步：Go 操作 Kafka
真正开发：
不会手敲命令。
而是：
Go代码操作Kafka二十六、安装 Go Kafka 库
go get github.com/segmentio/kafka-go二十七、Go 发送消息（生产者）
producer.go
packagemainimport("context""fmt""github.com/segmentio/kafka-go")funcmain(){// 创建生产者w:=kafka.NewWriter(kafka.WriterConfig{Brokers:[]string{"localhost:9092"},Topic:"order-topic",})// 发消息err:=w.WriteMessages(context.Background(),kafka.Message{Value:[]byte("hello kafka"),},)iferr!=nil{panic(err)}fmt.Println("发送成功")}二十八、运行生产者
go run producer.go二十九、Kafka 里已经有消息了
现在：
消费者：
就能读到。
三十、Go 消费消息（消费者）
consumer.go
packagemainimport("context""fmt""github.com/segmentio/kafka-go")funcmain(){// 创建消费者r:=kafka.NewReader(kafka.ReaderConfig{Brokers:[]string{"localhost:9092"},Topic:"order-topic",GroupID:"g1",})for{// 读取消息msg,err:=r.ReadMessage(context.Background())iferr!=nil{panic(err)}fmt.Println(string(msg.Value))}}三十一、运行消费者
go run consumer.go三十二、消费者会打印
hello kafka三十三、现在你已经真正会 Kafka 了
你已经掌握：
Kafka 启动
dockerrun创建 Topic
kafka-topics.sh发送消息
kafka-console-producer.sh或者：
WriteMessages()消费消息
kafka-console-consumer.sh或者：
ReadMessage()三十四、真实项目中的 Kafka 流程
真实开发：
最经典：
就是：
用户下单
订单服务：
发 Kafka 消息Kafka
负责：
存消息其他服务
消费：
- 库存
- 短信
- 推荐
- 邮件
三十五、Kafka 为什么重要
因为：
现代后端：
越来越：
微服务化系统之间：
不再：
直接调用而是：
通过 Kafka 通信三十六、最后一句总结（必须记住）
Kafka 最核心操作流程：
启动 Kafka ↓ 创建 Topic ↓ Producer 发消息 ↓ Topic 存消息 ↓ Consumer 读消息真正重要：
先掌握：
发 收别一开始：
研究：
Partition Offset 副本机制容易直接劝退。