3节点Kafka集群执行seek与poll操作偶发返回无记录问题咨询

场景1：循环内重复创建Consumer实例偶发无数据 #

Kafka Consumer的元数据加载是懒加载机制：你调用assign()和seek()方法只会在本地记录分区分配关系和目标偏移量，不会主动向集群发起元数据请求，只有第一次调用poll()的时候，客户端才会从bootstrap.servers列表中随机选择节点拉取分区元数据（包括分区leader节点地址、ISR列表等）。
当集群有1个节点离线时，新Consumer实例有1/3概率首次元数据请求打到离线节点，触发客户端重试逻辑。你设置的poll()超时只有2000ms，若元数据重试流程在超时前未完成，poll()就会直接返回空集合，表现为偶发"No Records Found"。

场景2：单Consumer实例复用仅首次偶发无数据 #

当Consumer实例复用的情况下，第一次poll()无论是否拉到数据，都已经完成了元数据的初始化和可用leader节点的探测，后续的poll()请求会直接和已经确认可用的分区leader通信，不会再触发元数据重试的流程，因此后续所有请求都能正常返回数据。

为了排除客户端侧逻辑干扰，准确测试集群可用性，可做以下调整：

• 主动触发元数据加载：在assign()和seek()之后，先调用consumer.position(partition)方法，主动拉取分区元数据，完成后再执行poll()操作
• 调整超时参数：将poll()的超时时间调整为5000ms以上，给元数据重试预留足够时间
• 调整客户端重试配置：新增以下配置降低重试延迟：

config.put(ConsumerConfig.RETRIES_CONFIG, 3);
config.put(ConsumerConfig.RETRY_BACKOFF_MS_CONFIG, 200);

• 提前确认集群状态：测试开始前验证离线节点对应的分区leader已经完成切换，ISR列表符合预期，排除集群侧未完成故障转移的影响。

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