Azure Event Hubs for Kafka消费者加入消费组请求超时问题咨询

核心问题排查点 #

• 检查session.timeout.ms参数配置
  Azure Event Hubs for Kafka对会话超时时间有强制限制，取值范围为6000ms~30000ms，你当前配置的100000ms远超上限，会被服务端直接拒绝请求，导致加入消费组超时，需修改为≤30000的值，例如：

  session.timeout.ms = 30000
  

• 检查max.poll.interval.ms参数配置
  Azure Event Hubs for Kafka限制最大拉取间隔不能超过300000ms（5分钟），你当前配置的2147483647超出限制，同样会触发服务端拒绝，需修改为≤300000的值，例如：

  max.poll.interval.ms = 300000
  

• 验证网络连通性
  确认运行消费者的服务器出站规则已开放9093端口，没有防火墙、代理拦截SASL_SSL协议的流量，可通过nc命令验证端口连通性：

  nc -zv xxxx-eventhubs-namespace.servicebus.windows.net 9093
  

• 检查SASL认证配置
  确认sasl.jaas.config配置格式正确，必须使用完整的Event Hubs连接字符串，示例配置如下：

  sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="Endpoint=sb://xxxx-eventhubs-namespace.servicebus.windows.net/;SharedAccessKeyName=XXXX;SharedAccessKey=XXXX";
  

• 验证消费组状态
  登录Azure门户查看对应Event Hubs实例的消费组列表，确认XXXGroupConsumer没有异常状态，如有必要可删除原有消费组后重新创建，避免旧的异常连接占用消费组配额。
• 检查Event Hubs资源状态
  登录Azure门户查看Event Hubs命名空间的指标，确认是否存在吞吐量单位（TU）不足导致的限流，如有限流告警可临时提升TU阈值验证问题是否解决。
• 排除自定义代码问题
  临时将value.deserializer替换为官方的org.apache.kafka.common.serialization.StringDeserializer测试，排除自定义反序列化类初始化异常导致的请求阻塞超时。

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