使用@KafkaListener(topicPattern)配置Kafka消费者时遇LEADER_NOT_AVAILABLE错误

我来帮你排查这个问题，结合你用topicPattern匹配主题的场景，大概率是这几个原因导致的，咱们一步步来解决：

1. 先确认匹配的主题是否真的存在 #

你发送消息的sss.test、sss.xyz这些主题，有没有在Kafka集群里实际创建？Kafka默认会自动创建不存在的主题，但如果集群里auto.create.topics.enable被改成了false，这些主题就不会自动生成，消费者自然找不到leader。

• 先手动创建一个主题试试：执行命令

  kafka-topics.sh --create --topic sss.test --bootstrap-server <你的Broker地址> --partitions 1 --replication-factor 1
  

  然后再发送消息，看警告是否消失。
• 检查Broker的server.properties里auto.create.topics.enable的值，确保是true（如果需要自动创建主题的话）。

2. 调整消费者的元数据刷新频率 #

用主题模式（topicPattern）的时候，消费者需要定期刷新元数据来发现新的匹配主题。默认的刷新间隔是5分钟，如果你刚创建主题就发消息，消费者可能还没更新元数据，就会报找不到leader的错。

• 在你的消费者配置里加个参数，把元数据刷新时间改短点，比如30秒：

  spring.kafka.consumer.metadata-max-age-ms=30000
  

  这样消费者会更快发现新的匹配主题。

3. 确认通配符配置是否被正确解析 #

你配置的kafka.topics=sss.*语法是对的（Kafka里*匹配任意字符序列），但要确保配置文件里的值没有被转义或者解析错误。

• 可以在代码里加个日志，打印@Value("${kafka.topics}")拿到的值，确认实际是sss.*而不是其他奇怪的内容（比如有些配置工具可能会把*转义成别的）。

4. 再检查Broker的监听配置是否真的生效 #

你已经配了listeners和advertised.listeners，但要确保这两个配置是消费者能访问到的：

• listeners是Broker绑定的地址，比如PLAINTEXT://0.0.0.0:9092（允许所有网卡访问）
• advertised.listeners是Broker对外暴露的地址，必须是消费者能连通的——如果消费者和Broker不在同一台机器，这里绝对不能写localhost，得用Broker的内网IP或者公网IP
• 重启Broker后，用命令查看主题的leader状态：

  kafka-topics.sh --describe --topic sss.test --bootstrap-server <你配置的advertised.listeners地址>
  

  如果输出里Leader显示的是一个数字（比如0，单节点集群的话），说明leader正常；如果是none，那还是Broker的监听配置有问题。

5. 确保消费者的bootstrap-servers和Broker的暴露地址一致 #

消费者配置的bootstrap-servers必须和Broker的advertised.listeners完全匹配，比如Broker的advertised.listeners是PLAINTEXT://192.168.1.100:9092，那消费者的spring.kafka.bootstrap-servers也得是这个地址，不能用localhost:9092（除非消费者和Broker在同一台机器）。

6. 多节点集群的话，排查副本同步问题 #

如果是多节点集群，可能存在副本同步失败的情况：

• 用刚才的kafka-topics.sh --describe命令查看ISR（In-Sync Replicas）列表，确认里面有可用的副本
• 去每个Broker的日志里看看，有没有副本同步失败的错误信息，比如网络不通、磁盘满了之类的。

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