kafka消费者问题：创建消费者后连接断开：Kafka + kubernetes
kafka consumer issue: connection drop after consumer is created: Kafka + kubernetes
我正在尝试构建所提到的确切基础设施 here
基本上，这篇文章专门用于根据读取 Stackdriver 指标进行缩放 pods（堆栈驱动器从 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)
截图：
我只有一个 GKE 集群，其中包含 2 个节点 + 一个 Kafka 计算引擎实例。没有特殊设置。我只是在关注上面的文章。
我不知道我应该调试什么，因为生产者在工作，但消费者没有。
如果有人能提供帮助，我们将不胜感激。
原来是防火墙问题。我只是允许节点网络，而它需要允许 pod 网络和服务网络运行。
我正在尝试构建所提到的确切基础设施 here
基本上，这篇文章专门用于根据读取 Stackdriver 指标进行缩放 pods（堆栈驱动器从 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)
截图：
我不知道我应该调试什么，因为生产者在工作，但消费者没有。
如果有人能提供帮助，我们将不胜感激。
原来是防火墙问题。我只是允许节点网络，而它需要允许 pod 网络和服务网络运行。