在 AKS 上部署 Kafka 并能够对其进行测试

Question

我已经使用“https://medium.com/@oleksii/how-to-deploy-apache-kafka-cluster-zookeeper-in-kubernetes-c5b04f01ac20”部署了 Kafka 和 Zookeeper

我使用https://github.com/PharosProduction/tutorial-apache-kafka-cluster 作为源代码。我可以使用 localhost:port 在内部测试生产者和消费者，并且工作正常。当我尝试使用负载均衡器 IP 地址时，它不起作用。有人可以帮帮我吗 。

Answer 1

如果您想访问集群内运行的服务，您需要将它们暴露在外部。将 service.yaml 文件中的服务类型从 ClusterIP 更新为 LoadBalancer。这应该为您的 Kafka 创建一个可公开访问的端点。您可以通过运行kubectl get services 查看公共 IP 地址。

您可能需要更新 kafka 服务 2 和 3 以在不同的端口（例如 9093,9094）上运行，以使其可公开访问。

除了测试目的之外，这种运行 Kafka 的方法可能不是很有用。没有一个 Kafka pod 具有持久存储，这使您的主题容易受到数据丢失的影响。