SpringBoot监听Kafka Topic无限挂起（pollThreadStateProcessor为null）

1. Kafka监听器反应式流未触发执行 #

你的监听器方法返回Mono<Void>，但Spring Kafka默认不会自动订阅反应式流。仅返回Mono而不触发订阅的话，流会一直处于未执行状态，直接导致Kafka消费线程被挂起，进而阻塞整个应用流程，包括WebClient请求也无法正常处理。

修复方式： #

• 手动订阅Mono确保流执行：

@KafkaListener(topics = "subscription-topic", groupId="groupId")
public void listener(@Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) final String key,
                     @Payload final String message) {
    someFunctionThatCallsAWebClient()
        .subscribe(
            () -> logger.info("请求执行完成"),
            err -> logger.error("请求失败", err)
        );
}

• 或者启用Spring Kafka的反应式支持，通过ReactiveKafkaConsumerTemplate配置反应式监听器，让框架自动处理流的订阅逻辑。

2. AdminClient连接Broker失败 #

控制台打印的Node -1 disconnected错误，说明Kafka客户端（包括AdminClient）无法正确连接到Broker，常见诱因：

• Bootstrap Servers配置不匹配：检查应用配置文件中spring.kafka.bootstrap-servers是否指向Broker实际监听的9093端口，地址是否正确（比如是否是localhost:9093）。
• Broker配置异常：本地Kafka的server.properties中listeners参数需和客户端配置一致，比如Broker要配置PLAINTEXT://localhost:9093才能被客户端正确识别。
• Broker未正常启动：确认本地Kafka服务已启动，9093端口未被防火墙或其他进程占用。

修复方式： #

• 核对Broker的server.properties，确保listeners配置为PLAINTEXT://localhost:9093（或对应你的主机IP）。
• 同步客户端配置：

spring:
  kafka:
    bootstrap-servers: localhost:9093
    consumer:
      group-id: groupId
      auto-offset-reset: earliest

• 用Kafka自带的终端工具再次验证Broker连接，确保终端能正常通信的情况下，客户端配置和终端使用的参数一致。

3. clearThreadState无限调用的关联问题 #

KafkaMessageListenerContainer中clearThreadState方法无限调用，是消费线程被阻塞后的连锁反应。当消费线程因Mono未订阅挂起时，Kafka消费循环无法正常推进，进而反复触发线程状态清理逻辑。解决上述两个核心问题后，该现象会自动消失。

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