Go 语言用 Kafka 必须显式配置 sarama.Version 和 Producer.RequiredAcks = sarama.WaitForAll，否则易丢消息、超时或静默失败；同步生产者还需开启 Producer.Return.Successes = true 并设合理 Timeout。
Go 语言用 Kafka，别直接抄 sarama.NewConfig() 默认配置——90% 的丢消息、超时、静默失败都源于它没设对。
同步生产者必须显式设 RequiredAcks = sarama.WaitForAll
默认 sarama.NewConfig() 的 Producer.RequiredAcks 是 sarama.NoResponse，意味着发完就不管 Broker 是否写入成功。网络抖动、Broker 重启、ISR 缩容时，消息直接消失，SendMessage 还返回 nil 错误。
- 只在确认强一致性场景（如订单、支付）才用同步模式
-
RequiredAcks = sarama.WaitForAll要求所有 ISR 副本写入才返回，但会增加延迟 - 必须同时打开
Producer.Return.Successes = true，否则拿不到partition和offset，没法做幂等或重试定位 - Kafka 版本不匹配（比如用 3.6 却配
sarama.V0_10_0_1）会导致UNKNOWN_TOPIC_OR_PARTITION这类无提示错误
正确写法：
config := sarama.NewConfig() config.Version = sarama.V3_6_0 config.Producer.RequiredAcks = sarama.WaitForAll config.Producer.Return.Successes = true config.Producer.Timeout = 10 * time.Second
消费者用 ConsumerGroup 而非低阶 Consumer
手动管理 offset、rebalance、分区分配？别折腾。线上服务一出故障，Consumer 容易重复消费或跳过消息，尤其在扩容缩容或临时下线时。
立即学习“go语言免费学习笔记（深入）”；
-
ConsumerGroup自动处理分区再均衡、提交 offset、故障转移 - 务必在
ConsumeClaim内调用session.MarkMessage(message, "")，否则 offset 不提交，重启后重复拉取 - 避免在
ConsumeClaim外部做耗时操作（如 HTTP 请求），会阻塞整个分区消费 - 如果需要精确一次语义（exactly-once），得配合事务型生产者 + 幂等写入，不能只靠 ConsumerGroup
别忽略 Version 和 Timeout 这两个“静默杀手”
它们不报错，但会让消息卡住、连接假死、重试失效，排查起来像在猜谜。
-
config.Version必须和 Kafka 集群实际版本严格一致，差一个小版本（如 V3_5_0 vs V3_6_0）可能导致元数据请求失败、topic 创建失败 -
Producer.Timeout控制单次发送最大等待时间，太短（如 1s）会让重试来不及触发；太长（如 60s）又拖垮整体吞吐 -
Consumer.Group.Rebalance.Timeout和Session.Timeout影响 rebalance 效率，云环境网络延迟高时需适当调大 - 本地开发连 Docker Kafka 时，
bootstrap.servers别写localhost:9092，要填容器内可访问地址（如host.docker.internal:9092）
公网或云 Kafka（如腾讯云 CKafka）要配 SASL/SSL
不是加个用户名密码就行。SASL 认证失败时，sarama 往往只报 EOF 或连接拒绝，根本看不出是鉴权问题。
- 必须设置
config.Net.SASL.Enable = true，并填config.Net.SASL.User和config.Net.SASL.Password - 若用
PLAIN机制，还要设config.Net.SASL.Mechanism = sarama.SASLMechanismPlaintext - SSL 接入点必须提供 CA 证书路径（
config.Net.TLS.Config），否则 TLS 握手失败，错误信息极简 - 腾讯云/阿里云 Kafka 控制台生成的接入点，注意区分
plaintext/SASL_PLAINTEXT/SASL_SSL类型，配错协议直连不上
最常被跳过的其实是 config.Version 和 RequiredAcks 的组合校验——它们不报错，但一起失效时，你看到的只是“消息发不出去”或“消费停了”，而日志里什么线索都没有。
