Docker环境下Kafka连接报错：tcp/9092端口解析异常

背景信息 #

• docker-compose.yaml配置：包含zookeeper、kafka1、edgenode-peer0-org1等服务，KAFKA_ADDR环境变量设为kafka1:9092
• Go代码：通过os.Getenv获取KAFKA_ADDR，调用Sarama的NewConsumer初始化消费者
• 验证情况：容器内通过curl可连通kafka1:9092，ZooKeeper中Kafka broker信息正常

问题原因 #

报错本质是代码中使用的Kafka地址格式非法，出现了tcp/9092这种错误格式——正常Kafka连接地址应为host:port，错误格式可能来自两个场景：

1. 环境变量值被意外带上引号或多余前缀，导致代码解析时拆分出错
2. 代码中错误地对地址进行了格式拼接（比如额外添加tcp/前缀）

修复步骤 #

• 检查环境变量实际值：在容器内执行echo $KAFKA_ADDR，确认输出是纯kafka1:9092，无引号或其他前缀。若docker-compose.yaml中环境变量写为KAFKA_ADDR="kafka1:9092"（带双引号），需改为KAFKA_ADDR=kafka1:9092，避免引号被带入环境变量值。
• 修正代码逻辑：确保获取环境变量后直接使用，无需添加tcp://或tcp/前缀。Sarama的NewConsumer接受的broker列表是标准host:port格式的字符串切片，示例代码如下：

kafkaAddr := os.Getenv("KAFKA_ADDR")
consumer, err := sarama.NewConsumer([]string{kafkaAddr}, nil)
if err != nil {
    // 错误处理逻辑
}

• 重启容器：修改配置和代码后，重新构建镜像并启动容器，验证连接是否正常。

内容的提问来源于stack exchange，提问作者ianhui