sarama.consumer收不到消息主因是config关键字段未显式设置：consumer.return.errors必须为true，consumer.offsets.initial须设offsetoldest/newest，net.dialtimeout/readtimeout建议≥10s；应改用asyncproducer并监听successes/errors通道，启用idempotent保障不丢不重。

sarama.Consumer配置不生效，新消费者组收不到消息

绝大多数情况不是Kafka集群问题，而是sarama.Config里几个关键字段没显式设置，导致消费者静默失败。

• Consumer.Return.Errors必须设为true，否则offset越界、rebalance失败等错误全被吞掉，日志里什么都没有
• Consumer.Offsets.Initial不能依赖默认值（它是0），新group首次启动必须明确指定sarama.OffsetOldest或sarama.OffsetNewest，否则Kafka查不到committed offset会报UnknownMemberId然后退订
• 本地连Docker Kafka时，Net.DialTimeout和Net.ReadTimeout建议至少设成10 * time.Second，网络抖动容易触发连接中断且不重试

用sarama.AsyncProducer替代SyncProducer发事件

sarama.SyncProducer阻塞调用、超时难控制、不支持批量，不适合微服务场景下的事件发布。

• 改用sarama.AsyncProducer，它把消息投进内部channel后立即返回，吞吐更高
• 必须监听Successes()和Errors()两个channel，否则成功/失败都不可见
• 开启幂等性：Config.Producer.Idempotent = true，能保证单producer单topic内不丢不重（但跨topic事务仍不支持）

Kafka消息体结构设计容易踩的坑

Go struct直塞JSON到Kafka，上线后加字段或删字段，消费者立刻panic——这不是Kafka的问题，是序列化契约没管住。

Golang Samber Hot

在 Golang 中使用 samber/hot 进行内存缓存，支持 LRU、LFU、TinyLFU、W‑TinyLFU、S3FIFO、ARC、TwoQueue、SIEVE、FIFO 等淘汰算法，提供 TTL、缓存加载器及分片功能。

下载

• 消息体最外层加v字段，比如{"v":"1.2","data":{...}}，消费者按版本分支解析，老版本逻辑不受影响
• 别直接序列化time.Time，不同Go版本、不同语言消费者对零值/时区处理不一致；统一转成time.Format(time.RFC3339)字符串或UnixMilli()整数
• Topic名带service和event语义，比如user-service.user-registered.v1，方便权限隔离、监控追踪、schema演进

Kratos框架里集成kafka-go比sarama更轻量

如果项目已用Kratos，且不需要Kafka 0.11+事务API，kafka-go比sarama更省心：配置少、API直白、资源占用低。

• kafka-go.Writer默认支持批量、重试、背压，Balancer可选LeastBytes或Hash，不用自己实现分区逻辑
• kafka.Reader自动管理offset提交，只要不显式调CommitMessages，就走auto-commit；需要精确控制时再手动commit
• 注意kafka.Reader.Config.MaxWait和MinBytes要配合调，否则小流量下消费延迟高——默认MaxWait=100ms，但MinBytes=1，实际是“有消息立刻拉”，大流量才攒批

Kafka在Go微服务里真正难的不是连上，而是消息语义的稳定性：version字段漏加、time字段裸传、topic命名模糊，这些问题上线后根本没法热修复。

golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！