go用kafka收发消息核心是选对sarama客户端并配准version、requiredacks、advertised.listeners三参数：version须显式设为v2_8_0_0起，requiredacks至少waitforlocal，advertised.listeners需与客户端连接地址一致。
Go 用 Kafka 发消息和收消息，核心就两件事：选对客户端、配对关键参数。别被“教程”带偏——sarama 是最成熟的选择，但默认配置下极易发不出消息或收不到数据，问题几乎都出在版本兼容、ACK 策略和 broker 地址这三处。
为什么 sarama.NewSyncProducer 一运行就报错或静默失败
同步生产者看似简单，但 NewSyncProducer 默认不校验 broker 连通性，也不等任何确认就返回，错误常被吞掉。更常见的是 Kafka 版本与 sarama 不匹配，比如用 v0.10.2 的 Kafka 却没设 config.Version，会直接卡在元数据请求上。
-
config.Version必须显式设置，推荐从sarama.V2_8_0_0（对应 Kafka 2.8+）起步，低于 0.10.0 的老集群才考虑V0_10_0_0 -
config.Producer.RequiredAcks别用默认的sarama.NoResponse，至少设为sarama.WaitForLocal，否则消息可能写入 leader 就返回，broker 挂了就丢 - 启动前务必用
telnet 127.0.0.1 9092或nc -zv 127.0.0.1 9092确认端口通——Kafka 默认监听localhost:9092，但advertised.listeners若配成PLAINTEXT://192.168.x.x:9092，Go 客户端连 localhost 就会超时
sarama.Consumer 收不到消息？先看 offset 和 group.id
消费者收不到消息，90% 是因为 offset 位置不对，或者 group.id 配错了。Kafka 不是“发了就能收”，它只把新消息推给 group 里还没消费过的 partition。
初始化并管理阿里云SDK Go 客户端，涵盖 sync.Once 单例、goroutine 安全、endpoint 与 region 配置、VPC 端点及调试。
- 首次启动消费者时，
config.Consumer.Offsets.Initial决定从哪开始读：sarama.OffsetOldest从头读，sarama.OffsetNewest只收启动后的新消息 -
group.id必须一致且非空；相同group.id的多个消费者会自动分摊分区，但若只有一个消费者却收不到，检查是否 topic 分区数 > 1 而该消费者只被分配到空分区 - 别依赖自动提交——
config.Consumer.Offsets.AutoCommit.Enable = true有延迟（默认 1s），测试时建议关掉，手动调consumer.CommitOffsets()确保可见
异步生产用 sarama.AsyncProducer，但别忽略 Successes 和 Errors channel
AsyncProducer 性能好，但把错误藏得更深。它不阻塞主 goroutine，所有结果都走 channel，如果你不读 producer.Successes() 或 producer.Errors()，消息丢了也完全不知道。
- 必须启动 goroutine 持续读取
producer.Errors()，否则 channel 堵塞会导致后续消息无法入队 -
config.Producer.Return.Successes和config.Producer.Return.Errors都要设为true，否则对应 channel 为 nil - 别在循环里反复
newAsyncProducer——它是线程安全的，应复用单例，否则连接和 goroutine 泄露极快
真正难的不是写几行 send/receive，而是让每条消息可追溯、每个 error 可捕获、每次重启后 offset 不漂移。Kafka 的“可靠”是配置出来的，不是开箱即来的。尤其在本地调试时，advertised.listeners、Version、RequiredAcks 这三个地方，少设一个，就等于没连上。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
