redpanda是兼容kafka协议的独立服务，需用标准kafka客户端接入；选segmentio/kafka-go因其纯go实现、无cgo依赖、部署简单，且v0.4+已适配redpanda 0.24+的kafka v3.0+协议。
Redpanda 在 Go 系统中不是 Kafka 的“平替”，而是需要明确按 Kafka 兼容协议接入的独立服务——它不提供原生 Go SDK，所有通信走 SASL_PLAINTEXT 或 SASL_SSL 协议，用标准 Kafka 客户端即可，但默认配置极易连不上。
为什么用 segmentio/kafka-go 而不是 confluent-kafka-go
segmentio/kafka-go 是纯 Go 实现，无 CGO 依赖，部署简单；confluent-kafka-go 底层调用 librdkafka，需编译环境和动态链接，CI/CD 和容器镜像里容易出 librdkafka.so not found 错误。Redpanda 0.24+ 对 Kafka v3.0+ 协议支持良好，kafka-go v0.4+ 已适配。
实操建议：
- 用
go get github.com/segmentio/kafka-go@v0.4.4（避免 v0.5+ 的 context deadline 默认行为变更） - 连接字符串必须含
bootstrap.servers，且地址格式为redpanda-0:9092（不是http://...） - 若 Redpanda 启用了 SASL，
username和password必须通过kafka.GoConfig的Auth字段传入，不能拼在 URL 里
kafka.Writer 写入时卡住或报 context deadline exceeded
这不是网络超时，而是 Redpanda 默认要求 ACK 级别为 all（即 ISR 全部副本写入成功），而单节点本地开发环境常只启一个 broker，导致 min.insync.replicas=2 不满足，写入挂起。
排查与修复：
- 查 Redpanda 配置：
docker exec -it redpanda-0 rpk cluster config get min.insync.replicas，开发环境应设为1 - Go 端显式指定
RequiredAcks: kafka.RequireOne，否则kafka-go默认用RequireAll - 确保
topic已存在，kafka-go的Writer不自动创建 topic（Redpanda 默认enable.auto.create.topics=false）
消费端 offset 提交失败：报 UNKNOWN_MEMBER_ID 或 REBALANCE_IN_PROGRESS
Redpanda 对 consumer group 协议实现比 Kafka 更严格，kafka-go 默认心跳间隔（HeartbeatInterval）是 3s，但 Redpanda 要求 session.timeout.ms > heartbeat.interval.ms × 3，否则组协调器反复踢出成员。
关键参数对齐：
SessionTimeout: 15 * time.SecondHeartbeatInterval: 3 * time.Second-
CommitInterval: 5 * time.Second（避免高频提交压垮 coordinator） - 务必设置
GroupID，且不同服务不能复用同一GroupID（否则 offset 冲突）
真正麻烦的是 schema 注册和序列化——Redpanda 自身不带 Schema Registry，如果要用 Avro，得额外搭 confluentinc/schema-registry 并确保 schema.registry.url 可达，而 JSON 直接序列化又容易因字段类型漂移引发消费崩溃。这事没法绕开，得提前选型。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
