KafkaTemplate.send()无返回无异常，SpringKafka无法向Azure EventHub发消息

1. 检查Azure Event Hub资源状态与配额 #

• 登录Azure门户查看目标Event Hub命名空间：
  • 确认是否达到吞吐量单位（TU）配额上限，TU耗尽会触发生产者限流，导致无日志的阻塞状态。
  • 检查Event Hub分区负载，若所有分区满负载，新消息无法写入也会引发阻塞。
  • 核实命名空间的防火墙/虚拟网络规则，是否上周新增IP限制导致应用所在Azure节点IP被拦截。

2. 调整生产者超时与日志配置 #

当前日志无法定位问题，先强制开启底层日志并设置超时：

• 添加日志配置到application.yml：

  logging:
    level:
      org.apache.kafka: DEBUG
      org.springframework.kafka: DEBUG
  

  这会输出Kafka客户端的连接、请求响应等底层交互日志，便于排查阻塞原因。
• 配置生产者超时参数，避免无限阻塞：

  spring:
    kafka:
      producer:
        properties:
          max.block.ms: 30000  # 30秒超时后抛出TimeoutException
          request.timeout.ms: 15000
          delivery.timeout.ms: 30000
  

3. 验证Azure Event Hub的Kafka兼容配置 #

确认你的生产者配置符合Azure Event Hub的Kafka要求：

• 检查bootstrap-servers格式是否为{namespace}.servicebus.windows.net:9093
• 确认安全配置正确：

  spring.kafka.producer.properties.security.protocol=SASL_SSL
  spring.kafka.producer.properties.sasl.mechanism=PLAIN
  spring.kafka.producer.properties.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="你的Event Hub连接字符串";
  

  注意连接字符串中的特殊字符需正确转义。

4. 排查Azure应用服务网络变更 #

• 若应用部署在Azure App Service，检查网络配置：是否上周开启VNet集成但未配置Event Hub的VNet访问权限；或App Service出站IP地址变更，被Event Hub防火墙拦截。
• 在本地用相同配置运行应用，验证是否能正常发送，排除Azure环境问题。

5. 检查版本兼容性 #

Spring Boot 3.1.7对应Spring Kafka 3.0.10，基于Kafka客户端3.3.x，可尝试升级Kafka客户端版本：

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>3.4.0</version>
</dependency>

6. 排查线程阻塞情况 #

• 在Azure App Service开启应用洞察（Application Insights），查看线程快照，确认KafkaTemplate.send()调用线程的阻塞状态及原因（如等待网络响应、锁资源等）。

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