sarama.NewSyncProducer连不上Kafka主因是环境未对齐：ZooKeeper/Kafka启动顺序错误、listeners配置不匹配、Version与Kafka服务端版本不一致，或RequiredAcks等关键配置未显式设置。
直接上手写 sarama.NewSyncProducer 却连不上 Kafka？八成是环境没对齐，不是代码写错了。Kafka 本地开发必须先跑通 ZooKeeper（或 KRaft），再起 Kafka，否则客户端会卡在 dial tcp 127.0.0.1:9092: connect: connection refused 或静默报 UNKNOWN_TOPIC_OR_PARTITION。
启动 ZooKeeper 和 Kafka 的顺序与配置要点
新手务必走 ZooKeeper 模式——文档全、报错明确、调试方便。KRaft 虽从 Kafka 3.3+ 稳定，但团队协作中版本混淆风险高，不建议初期尝试。
关键检查点：
-
zookeeper.properties中的dataDir必须指向一个真实可写的目录（如/tmp/zk-data），否则启动失败且日志无明显提示 -
server.properties中listeners和advertised.listeners必须匹配本地地址。开发机用localhost就填PLAINTEXT://localhost:9092，别留默认的0.0.0.0 - 先执行
bin/zookeeper-server-start.sh config/zookeeper.properties，等日志出现binding to port再起 Kafka；再执行bin/kafka-server-start.sh config/server.properties，末尾看到started (kafka.server.KafkaServer)才算成功
sarama.NewConfig() 默认值是生产事故的起点
刚 go get github.com/Shopify/sarama 就调 NewSyncProducer？大概率发消息不报错但 Broker 根本没收到——因为 RequiredAcks 默认是 sarama.NoResponse，发完就返回，连 broker 是否在线都不校验。
立即学习“go语言免费学习笔记（深入）”；
必须显式覆盖这四项：
在 Go 中使用 google/wire 实现编译时依赖注入——wire.NewSet、wire.Build、wire.Bind（接口→实现）、wire.Struct、wire.Value、wire.Interface
-
config.Version = sarama.V3_6_0：按你实际安装的 Kafka 小版本填，填错会静默失败或报UNSUPPORTED_VERSION -
config.Producer.RequiredAcks = sarama.WaitForAll：即acks=all，确保 ISR 全部写入才返回 -
config.Producer.Return.Successes = true：否则SendMessage不返回partition和offset，没法做幂等或追踪 -
config.Producer.Timeout = 10 * time.Second：太短易因网络抖动误判失败，太长阻塞业务逻辑
创建 topic 和验证连通性的最小闭环
别跳过命令行验证环节。很多“Go 连不上”问题，其实 Kafka 根本没正常提供服务。
用 Kafka 自带脚本快速走通：
- 创建 topic：
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --topic test --partitions 1 --replication-factor 1 - 手动发一条：
bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test，输入后 Ctrl+C - 手动收一条：
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --max-messages 1
只有这三步都成功，再跑 Go 代码才有意义。否则所有 Go 客户端错误都是干扰项。
Go 生产者代码里最容易漏掉的细节
哪怕配置全对，也常因两个小动作导致失败：
- 没检查
producer.Close()是否被正确 defer：不关闭会导致连接泄漏，多次重启后可能触发 Kafka 的连接数限制 - 用
sarama.StringEncoder时传了空字符串或 nil：会 panic，应先判空或用sarama.ByteEncoder([]byte(...))更可控 - topic 名含非法字符（如大写字母、下划线以外的符号）：Kafka 默认只允许 ASCII 字母、数字、点、连字符和下划线，
test_topic合法，test@topic会报INVALID_TOPIC_EXCEPTION
真正卡住人的，往往不是语法或逻辑，而是 ZooKeeper 数据目录权限、advertised.listeners 写成 127.0.0.1 却在 macOS 上用 localhost 连、或者 Kafka 版本和 sarama.Version 差一个小版本——这些点不打日志、不抛 panic，只让消息消失在黑盒里。
