Kafka适合强顺序、高吞吐、跨机房容灾场景，需正确配置acks=all、Version和Return.Successes；NSQ轻量零依赖，部署简单但需手动处理重连与连接复用。
Go 项目里选 Kafka 还是 NSQ，取决于你是否需要强顺序、高吞吐、跨机房容灾。Kafka 更重，NSQ 更轻；Kafka 依赖 ZooKeeper（或 KRaft 模式），NSQ 零依赖、单二进制即可跑通。
用 Sarama 连 Kafka：同步生产者必须设 acks=all，否则大概率丢消息
很多线上事故都源于默认配置——sarama.NewConfig() 的 Producer.RequiredAcks 默认是 sarama.NoResponse，即发完就不管了。哪怕 Broker 挂了，SendMessage 也返回成功。
- 必须显式设为
sarama.WaitForAll，确保 ISR（同步副本）全部写入才返回 -
config.Producer.Return.Successes = true要打开，否则SendMessage不返回 partition/offset，也没法做幂等校验 - 别忽略
config.Version，比如用 Kafka 3.6+ 却配sarama.V0_10_0_1，会静默失败或报UNKNOWN_TOPIC_OR_PARTITION
config := sarama.NewConfig()
config.Version = sarama.V3_6_0 // 匹配你的 Kafka 版本
config.Producer.RequiredAcks = sarama.WaitForAll
config.Producer.Return.Successes = true
config.Producer.Timeout = 10 * time.Second
<p>producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, config)
if err != nil {
log.Fatal("NewSyncProducer failed:", err)
}
defer producer.Close()</p><p>msg := &sarama.ProducerMessage{
Topic: "orders",
Value: sarama.StringEncoder("order_id=12345"),
}
partition, offset, err := producer.SendMessage(msg)</p>NSQ 部署极简，但 Go 客户端要注意 nsq.Producer 的连接复用和重连策略
NSQ 不需要 ZooKeeper，nsqd 单进程启动即用，适合中小团队快速验证异步解耦场景。但它的 Go 客户端 github.com/nsqio/go-nsq 默认不自动重连，网络抖动后容易卡死。
-
nsq.NewProducer创建后，需调用Connect()，并监听Errchannel 处理断连 - 不要每次发消息都新建
Producer，它内部维护 TCP 连接池，应全局复用 - 若用
nsqlookupd做服务发现，Producer初始化时要传LookupAddresses，否则无法自动发现 topic
cfg := nsq.NewConfig()
cfg.DialTimeout = 2 * time.Second
cfg.OutputBufferSize = 1024
<p>p, _ := nsq.NewProducer("127.0.0.1:4150", cfg)
p.SetLogger(nil, nsq.LogLevelError)</p><p>// 必须手动处理连接异常
go func() {
for err := range p.Err() {
log.Printf("NSQ producer error: %v", err)
// 这里可触发告警或降级逻辑
}
}()</p><p>err := p.Publish("user_events", []byte(<code>{"uid":1001,"action":"login"}</code>))</p><div class="aritcle_card flexRow">
<div class="artcardd flexRow">
<a class="aritcle_card_img" href="/ai/1354" title="阿里云AI平台"><img
src="https://img.php.cn/upload/ai_manual/001/431/639/68b6d5787ca97252.png" alt="阿里云AI平台" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a href="/ai/1354" title="阿里云AI平台">阿里云AI平台</a>
<p>阿里云AI平台</p>
</div>
<a href="/ai/1354" title="阿里云AI平台" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span> </a>
</div>
</div><p><span>立即学习</span>“<a href="https://pan.quark.cn/s/00968c3c2c15" style="text-decoration: underline !important; color: blue; font-weight: bolder;" rel="nofollow" target="_blank">go语言免费学习笔记（深入）</a>”；</p>Kafka 启动前必查三件事：advertised.listeners、ZooKeeper 状态、server.properties 中的 broker.id
本地跑不通 Kafka，90% 是网络配置问题。Kafka 不是“启动了就能连”，它会把 advertised.listeners 里的地址告诉客户端——如果填的是 localhost，而 Go 程序跑在 Docker 容器里，必然连不上。
-
开发环境建议设
advertised.listeners=PLAINTEXT://127.0.0.1:9092，避免 DNS 解析问题 - 先确认 ZooKeeper 已启动：
echo stat | nc localhost 2181应返回状态信息；若报Connection refused，说明 ZooKeeper 没起来 -
broker.id在集群中必须唯一；单机测试可固定为0，但删掉logs目录后务必清空meta.properties，否则启动报错Cluster ID mismatch
真正难的不是“怎么连上”，而是“怎么连得稳”。Kafka 的 ack 策略、NSQ 的心跳超时、Go 客户端的连接池大小——这些参数不调到业务水位线以上，压测一跑就暴露。别信“默认能用”，线上每个 config 字段背后都是血泪经验。
