远程运行KafkaConsumer无记录，本地正常问题求助

一、代码逻辑问题修正 #

你的消费代码中存在关键逻辑错误：每次调用poll拉取消息后，都执行了consumer.seekToBeginning(consumer.assignment());，强制将偏移量重置到分区起始位置。这会导致：

• 首次拉取若获取到消息，后续poll时，因为默认自动提交开启（提交间隔5000ms，与你的poll时长一致），broker认为该偏移量已被消费，不会重复返回消息，最终表现为持续拉取不到记录。
• 本地运行时可能因为消息是实时生产的，掩盖了这个逻辑问题，但远程环境下网络延迟等因素会让问题更明显。

修正方法：移除consumer.seekToBeginning(consumer.assignment());这一行代码；如果确实需要首次启动时从开头消费，可将该逻辑放在循环外，仅执行一次。

另外，建议使用新版pollAPI：将consumer.poll(5000)改为consumer.poll(Duration.ofMillis(5000))，避免过时API带来的潜在问题。

二、Kafka Broker配置调整（核心原因） #

远程机器能调用listTopics()成功获取主题，但无法拉取消息，本质是bootstrap服务器仅用于元数据获取，实际消费需要连接broker对外暴露的真实地址，这取决于Kafka的advertised.listeners配置：

• 若Kafka的server.properties中仅配置了listeners=PLAINTEXT://localhost:9092或PLAINTEXT://127.0.0.1:9092，本地运行时consumer可直接连接localhost的broker，但远程机器A收到broker返回的元数据后，会尝试连接localhost地址，显然无法访问。
• 解决配置：
  修改server.properties文件：

  listeners=PLAINTEXT://0.0.0.0:9092  # 允许broker监听所有网卡
  advertised.listeners=PLAINTEXT://220.220.220.220:9092  # 填写Kafka服务器远程可访问的IP（即你bootstrap.servers配置的IP）
  

  修改完成后重启Kafka服务。

三、网络与防火墙验证 #

• 确认远程机器A能访问Kafka服务器的9092端口：执行命令nc -zv 220.220.220.220 9092或telnet 220.220.220.220 9092，若连接失败，需在Kafka服务器上开放9092端口的防火墙规则。
• 注意：SSH端口（默认22）连通不代表9092端口可用，需单独验证。

四、验证流程 #

1. 修正消费代码中的逻辑错误，替换为新版pollAPI。
2. 调整Kafka broker的advertised.listeners配置并重启服务。
3. 在远程机器A上重新运行consumer程序，观察是否能正常拉取消息。

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