使用testcontainers-go Kafka模块启动confluent-local:7.5.0容器失败

我无法通过testcontainers/testcontainers-go的Kafka模块启动confluentinc/confluent-local:7.5.0的Kafka Testcontainer，但用GenericContainer能正常启动该镜像。相同代码在配置一致的同事电脑上能正常运行。我已经确认端口未被占用，试过延长上下文超时、调整Kafka Testcontainer等待超时、给Docker分配15GB内存，问题还是没解决。

相关代码 #

func main() {
    ctx := context.Background()

    kafkaContainer, err := kafka.RunContainer(ctx,
        kafka.WithClusterID("test-cluster"),
        testcontainers.WithImage("confluentinc/confluent-local:7.5.0"),
    )
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("Kafka is running")

    time.Sleep(30 * time.Second)

    // Clean up the container after
    defer func() {
        if err := kafkaContainer.Terminate(ctx); err != nil {
            log.Fatalf("failed to terminate container: %s", err)
        }
    }()
}

错误日志 #

...
🐳 Creating container for image confluentinc/confluent-local:7.5.0
✅ Container created: b6c3b701c2fa
🐳 Starting container: b6c3b701c2fa
✅ Container started: b6c3b701c2fa
port not found
context deadline exceeded
...

可行的解决方向 #

1. 明确指定端口映射 #

confluent-local默认暴露Kafka端口9092，但Kafka模块可能需要显式绑定端口，避免端口检测逻辑不匹配：

kafkaContainer, err := kafka.RunContainer(ctx,
    kafka.WithClusterID("test-cluster"),
    testcontainers.WithImage("confluentinc/confluent-local:7.5.0"),
    testcontainers.WithExposedPorts("9092/tcp"),
    kafka.WithPort(9092),
)

2. 自定义等待策略 #

confluent-local包含多组件，启动速度较慢，默认等待策略可能触发超时。可以改为等待日志关键词或延长超时：

kafkaContainer, err := kafka.RunContainer(ctx,
    kafka.WithClusterID("test-cluster"),
    testcontainers.WithImage("confluentinc/confluent-local:7.5.0"),
    testcontainers.WithWaitStrategy(
        wait.ForLog("Kafka Server started").WithStartupTimeout(5*time.Minute),
    ),
)

（日志关键词可根据镜像实际启动输出调整，找到Kafka服务就绪的标识）

3. 检查Docker网络配置 #

尝试指定Docker默认bridge网络，或创建自定义网络排除隐性差异：

kafkaContainer, err := kafka.RunContainer(ctx,
    kafka.WithClusterID("test-cluster"),
    testcontainers.WithImage("confluentinc/confluent-local:7.5.0"),
    testcontainers.WithNetwork("bridge"),
)

4. 对齐模块版本 #

确认你和同事使用的testcontainers-go Kafka模块版本一致，或尝试升级/降级版本，排查兼容性问题。

5. 覆盖Kafka启动配置 #

手动指定监听地址等配置，匹配confluent-local的启动逻辑：

kafkaContainer, err := kafka.RunContainer(ctx,
    kafka.WithClusterID("test-cluster"),
    testcontainers.WithImage("confluentinc/confluent-local:7.5.0"),
    kafka.WithConfig(map[string]string{
        "listeners": "PLAINTEXT://0.0.0.0:9092",
        "advertised.listeners": "PLAINTEXT://localhost:9092",
    }),
)

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