当 Kafka 消费者程序在远程机器运行时始终返回空记录，但在 Kafka 服务器本机运行正常，通常源于服务端 advertised.listeners 配置错误或网络可见性问题，而非客户端代码缺陷。
当 kafka 消费者程序在远程机器运行时始终返回空记录，但在 kafka 服务器本机运行正常，通常源于服务端 `advertised.listeners` 配置错误或网络可见性问题，而非客户端代码缺陷。
Kafka 消费者连接过程分为两个关键阶段：元数据发现（通过 bootstrap.servers 获取集群拓扑）和实际数据拉取（向具体 broker 的 advertised.listeners 地址发起请求）。你的程序在远程机器能成功调用 listTopics()，说明第一阶段（元数据连接）已通；但 poll() 返回空记录，表明第二阶段失败——消费者拿到了 broker 的元数据（如 leader 分区信息），却无法连接到该 broker 实际暴露的地址。
根本原因在于 Kafka 服务端配置缺失或错误。默认情况下，Kafka broker 启动后会将 listeners（监听地址）作为 advertised.listeners（对外宣告地址）使用。若 listeners 配置为 PLAINTEXT://localhost:9092 或内网地址（如 192.168.1.10:9092），而远程客户端通过公网 IP 220.220.220.220:9092 连接，则 broker 在返回的元数据中会告诉消费者：“该 topic 的 leader 在 localhost:9092”，导致消费者尝试连接 localhost（即它自己的本地回环），自然失败。
✅ 正确做法是显式配置 advertised.listeners，使其与客户端可访问的真实网络地址一致：
# server.properties 中必须设置（以 Kafka 3.3.1 为例） listeners=PLAINTEXT://0.0.0.0:9092 advertised.listeners=PLAINTEXT://220.220.220.220:9092
⚠️ 注意：advertised.listeners 必须是客户端网络可达的完整地址（IP + 端口），不能是 localhost、127.0.0.1 或内网地址；同时确保防火墙放行 9092 端口（TCP）且无 NAT/安全组拦截。
此外，建议按以下步骤系统排查：
- 启用客户端日志：添加 log4j.properties（如 log4j.rootLogger=INFO, stdout + Kafka 相关包设为 DEBUG），观察 ConsumerCoordinator 和 NetworkClient 日志，确认是否出现 Connection refused 或 TimeoutException；
- 验证服务端配置生效：重启 Kafka 后执行 kafka-broker-api-versions.sh --bootstrap-server 220.220.220:9092，检查响应中 node_id 对应的 host 是否为 220.220.220.220；
-
交叉验证工具链：使用官方命令行工具快速验证：
# 在远程机器执行（无需 Java 程序） kafka-console-consumer.sh \ --bootstrap-server 220.220.220:9092 \ --topic quickstart-events \ --from-beginning \ --max-messages 5
若该命令也失败，即可完全排除客户端代码问题，聚焦服务端配置与网络。
最后提醒：你代码中每轮循环都调用 consumer.seekToBeginning(consumer.assignment())，这会强制重置偏移量为最早位置，虽不影响连通性诊断，但在生产环境会导致重复消费，建议仅在调试初期使用，正式逻辑中应依赖自动提交或手动管理 offset。
