kafka消费者问题：创建消费者后连接断开：Kafka + kubernetes

Question

我正在尝试构建提到的确切基础设施here

基本上，这篇文章专门针对基于读取 Stackdriver 指标来扩展 Pod（堆栈驱动器从 Kafka 服务器接收流量并根据它进行扩展。）

在我创建生产者部署并按预期正常工作之前，一切正常。它能够连接到 Kafka 服务器，但是当我运行消费者部署时，它失败并在容器日志中显示以下错误。

% Error: 10.128.0.9:9092/bootstrap: Connect to ipv4#10.128.0.9:9092 failed: Operation timed out (after 128991ms in state CONNECT)

截图：
我只有一个带有 2 个节点的 GKE 集群 + 一个 Kafka 计算引擎实例。没有特殊设置。我只是在关注上面的文章。

我不知道我应该调试什么，因为生产者正在工作，而消费者却没有。

如果有人能提供帮助，将不胜感激。

Answer 1

原来是防火墙问题。我只是允许节点网络，而它需要允许 pod 网络和服务网络运行。