使用Dapr C#向KRaft模式Kafka发消息遇连接拒绝问题

针对你遇到的Dapr.DaprException: Publish operation failed: the Dapr endpoint indicated a failure错误，核心问题集中在Dapr Sidecar未正确启动、Kafka网络配置不兼容本地访问、Dapr组件未加载这几个方面，以下是具体修复步骤：

1. 必须通过Dapr Sidecar启动.NET应用 #

Dapr采用Sidecar模式，不能直接运行dotnet run，必须用dapr run命令将应用与Sidecar一起启动：

# Windows
dapr run --app-id dotnet-kafka-poc --dapr-grpc-port 50051 dotnet run

# Linux/macOS
dapr run --app-id dotnet-kafka-poc --dapr-grpc-port 50051 -- dotnet run

• --app-id：指定唯一的应用ID，Dapr通过这个标识管理组件
• --dapr-grpc-port：指定Sidecar的gRPC端口，需与代码中配置的端口一致（默认50051）

2. 修复Kafka的Docker网络配置 #

你的Kafka配置中，KAFKA_CFG_ADVERTISED_LISTENERS需要明确指向本地宿主机地址，否则Dapr无法正确连接Docker内的Kafka：
修改docker-compose.yaml中的环境变量：

environment:
  # ... 保留其他原有配置
  - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092
  # 删除或替换原有的KAFKA_ADVERTISED_HOST_NAME，Bitnami Kafka优先使用ADVERTISED_LISTENERS配置

修改后重启Kafka：

docker-compose down -v && docker-compose up -d

验证本地是否能连接Kafka：

# Windows使用telnet
telnet localhost 9092
# Linux/macOS使用nc
nc -zv localhost 9092

3. 确保Dapr PubSub组件正确加载 #

将你的Kafka组件yaml文件放到Dapr自托管模式的组件目录：

• Windows：%USERPROFILE%\.dapr\components
• Linux/macOS：$HOME/.dapr/components

组件文件无需修改，但要确认文件名后缀为.yaml（比如命名为kafka-pubsub.yaml），Dapr Sidecar启动时会自动加载该目录下的组件。

4. 优化.NET客户端的Dapr配置 #

简化ConfigureServices方法，避免手动指定端口时的空引用问题：

static void ConfigureServices(IServiceCollection services)
{
    // 优先使用环境变量，默认端口设为50051兜底
    string daprPort = Environment.GetEnvironmentVariable("DAPR_GRPC_PORT") ?? "50051";
    var grpcEndpoint = $"http://localhost:{daprPort}";

    var daprClient = new DaprClientBuilder()
        .UseGrpcEndpoint(grpcEndpoint)
        .Build();

    services.AddSingleton(daprClient);
}

或者用更简洁的写法（Dapr会自动发现Sidecar端口）：

static void ConfigureServices(IServiceCollection services)
{
    var daprClient = new DaprClientBuilder().Build();
    services.AddSingleton(daprClient);
}

5. 验证流程 #

1. 启动Kafka容器后，查看日志确认正常运行：docker logs kafka，确保包含kafka-topic已创建的日志信息
2. 执行dapr run命令启动Dapr与.NET应用
3. 查看Dapr Sidecar日志，确认组件加载成功：dapr logs --app-id dotnet-kafka-poc，日志中应出现kafka-pubsub组件初始化成功的记录

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