Docker Compose部署Kafka后，C#客户端远程连接超时，求配置建议

我来帮你一步步排查和解决这个连接超时的问题：

先确认基础运行状态 #

• 检查容器启动状态：
  运行docker-compose logs kafka查看Kafka容器日志，重点找是否有started (kafka.server.kafkaServer)的启动成功提示，以及是否成功连接Zookeeper（比如Session establishment complete on server zookeeper/172.x.x.x:2181这类日志）。如果日志里有Zookeeper连接失败、topic创建失败的信息，先解决这些基础问题。

• 测试网络连通性：
  在你的C#客户端机器上，用telnet 172.16.1.109 9092或者nc -zv 172.16.1.109 9092测试端口是否能通。如果不通，说明是网络/防火墙问题：

  • 检查宿主机防火墙是否开放9092端口（比如Ubuntu用ufw allow 9092，CentOS用firewall-cmd --add-port=9092/tcp --permanent && firewall-cmd --reload）
  • 确认172.16.1.109这个IP是客户端机器能正常访问的宿主机IP（如果客户端和宿主机不在同一局域网，可能需要用公网IP或配置端口转发）

调整Kafka容器配置 #

如果网络是通的，大概率是Kafka的监听配置问题。针对wurstmeister/kafka镜像，建议显式补充KAFKA_LISTENERS配置，确保Kafka监听所有容器接口，同时KAFKA_ADVERTISED_LISTENERS正确告知客户端连接地址：

修改你的docker-compose.yaml：

version: "2"
services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - 2181:2181
  kafka:
    container_name: kafka
    image: wurstmeister/kafka
    ports:
      - 9092:9092
    environment:
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092  # 显式指定监听所有容器接口
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://172.16.1.109:9092
      KAFKA_CREATE_TOPICS: "test:1:1"

修改后重启容器：docker-compose down && docker-compose up -d

优化C#客户端配置 #

如果还是超时，建议在客户端代码里增加调试日志和超时配置，定位具体问题：

以Confluent.Kafka客户端为例：

using Confluent.Kafka;
using System;
using System.Threading.Tasks;

class Program
{
    static async Task Main(string[] args)
    {
        var config = new ProducerConfig
        {
            BootstrapServers = "172.16.1.109:9092",
            RequestTimeoutMs = 10000,  // 延长超时时间
            Debug = "broker,topic,msg"  // 开启调试日志，查看详细交互过程
        };

        using var producer = new ProducerBuilder<Null, string>(config).Build();

        try
        {
            var result = await producer.ProduceAsync("test", new Message<Null, string> { Value = "Hello Kafka!" });
            Console.WriteLine($"消息已投递至: {result.TopicPartitionOffset}");
        }
        catch (ProduceException<Null, string> e)
        {
            Console.WriteLine($"投递失败: {e.Error.Reason}");
        }
    }
}

运行后查看控制台的调试日志，你能清楚看到客户端是卡在连接broker阶段，还是获取元数据阶段，从而精准定位问题。

额外注意点 #

• 如果客户端和Kafka容器在同一台宿主机，也可以尝试用localhost:9092作为bootstrap地址（前提是端口映射正常）
• 确认宿主机9092端口没有被其他进程占用：Linux用lsof -i :9092，Windows用netstat -ano | findstr :9092

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