newsyncproducer 不丢消息需设 requiredacks=waitforall、timeout≥10s、显式 close；topic 创建须用 clusteradmin；版本匹配、replicationfactor≤broker数；consumergroup 需非空 group.id，避免 time.sleep 控速。
同步生产者 NewSyncProducer 怎么用才不丢消息
同步生产者看似简单，但默认配置下其实很危险——SendMessage 返回成功，不代表消息已落盘。关键取决于 RequiredAcks 和 Timeout 的组合。
-
config.Producer.RequiredAcks = sarama.WaitForAll是底线：必须等所有 ISR 副本写入成功才返回，否则可能因 leader 切换丢失数据 -
config.Producer.Timeout至少设为 10s：Kafka 默认request.timeout.ms=30000，Go 客户端超时若更短，会提前报错中断，但 broker 端可能仍在重试 - 别忽略
defer p.Close()：不显式关闭会导致连接泄漏，尤其在短生命周期服务中容易触发too many open files - 示例里用
sarama.ByteEncoder([]byte("..."))而非sarama.StringEncoder更稳妥：后者对含 \x00 的二进制内容会截断
创建 Topic 必须走 ClusterAdmin，别硬敲命令
本地 kafka-topics.sh 创建的 topic 在多节点集群中可能分区不均、副本未就绪，而 Go 程序里用 NewClusterAdmin 可确保元数据实时生效，且能捕获权限/配额类错误。
- 版本必须匹配：
config.Version = sarama.V2_8_0_0（对应 Kafka 2.8+），低版本设高会导致UNKNOWN_TOPIC_OR_PARTITION -
ReplicationFactor不能大于可用 broker 数：设成 3 但只启了 2 个 broker，CreateTopic会卡住或返回Kafka: invalid configuration - 不要复用
AdminClient实例做高频操作：它内部有连接池和缓存，但长期运行需定期调用RefreshMetadata防止 topic 元数据过期
消费者用 ConsumePartition 还是 ConsumerGroup？看场景
单机调试或日志采集这类“每个实例消费全量”的场景，用 ConsumePartition 直接；但订单、支付等业务流，必须上 ConsumerGroup，否则无法实现负载分摊与 offset 自动提交。
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
-
ConsumePartition要自己管理 offset：从sarama.OffsetOldest或sarama.OffsetNewest启动后，得手动调pc.HighWaterMarkOffset()记录位置，否则重启就重头消费 -
ConsumerGroup的config.Group.ID不能为空字符串：空值会导致 consumer 拒绝加入 group，日志里只报group coordinator not available，很难排查 - 消费循环里别用
time.Sleep控速：会阻塞整个Messages()channel，正确做法是用config.ChannelBufferSize控制缓冲区大小，再配合context.WithTimeout处理单条超时
sarama 版本和依赖陷阱：为什么 go mod tidy 会清空 go.mod
这不是 bug，是 sarama v1.30+ 强制要求 Go 1.21+ 且启用 cgo，而旧版 go get 会拉取不兼容的 commit hash，导致模块解析失败后回退清空。
- 必须显式指定分支或 tag：
go get github.com/Shopify/sarama@v1.34.0，别信latest - 如果项目禁用
cgo（如交叉编译到 alpine），得切回v1.28.1并加// +build !cgo注释，否则编译报undefined: zstd.NewReader -
github.com/IBM/sarama是社区维护分支，API 兼容但修复更快；github.com/Shopify/sarama是官方源，更新慢但更稳定——生产环境建议锁死 IBM 分支
真正麻烦的是 Admin API 的权限控制：SASL/SSL 配置漏一项，CreateTopic 就静默失败，错误信息藏在 err.Error() 最末尾的嵌套字段里，得用 fmt.Printf("%+v", err) 才看得见。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
