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计算引擎实例。没有特殊设置。我只是在关注以上文章。
我不知道应该调试什么，因为生产者正在工作，而消费者没有。

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

[我正在尝试构建此处确切提到的基础，基本上，本文专门基于读取Stackdriver指标（堆栈驱动器从Kafka接收流量...]来扩展Pod。

原来是防火墙问题。我只是允许节点网络，而它要求允许Pod网络和服务网络正常工作。

Answer 1

原来是防火墙问题。我只是允许节点网络，而它要求允许Pod网络和服务网络正常工作。