在 Openshift 上外部访问 Kafka答案

【问题标题】：Externally accessing Kafka on Openshift在 Openshift 上外部访问 Kafka
【发布时间】：2019-10-01 22:02:46
【问题描述】：

我正在尝试使用这种将 Kafka 部署到 Openshift 的方法： https://github.com/mattf/openshift-kafka

部署设置完毕，我可以在容器内设置代理和消费者，它们工作正常。当我尝试使用控制台消费者（使用端口转发到我的本地计算机）访问主题时，我收到一条消息说代理不可用。

我尝试将 advertised.listeners=PLAINTEXT://openshiftRoute:80 覆盖添加到 yaml 文件，但现在我得到了 Error while fetching metadata with correlation id X : {test=LEADER_NOT_AVAILABLE}。

当我尝试使用 Openshift 路由到 localhost:9092 时

kafka-console-consumer.bat --bootstrap-server http://route:80 --topic test --from-beginning

我明白了

[2019-05-14 21:58:47,773] ERROR Error processing message, terminating consumer process:  (kafka.tools.ConsoleConsumer$)
java.lang.OutOfMemoryError: Java heap space

我在这里缺少什么，如何在 Openshift 中从外部访问 Kafka？

【问题讨论】：

标签： kubernetes apache-kafka openshift devops

【解决方案1】：

如果您想简化执行此操作的方式，可以尝试使用 Strimzi 项目 (https://strimzi.io) 在 Kubernetes 和 OpenShift 上部署和管理 Apache Kafka 集群。它提供了一种非常简单的方法来使用路由在 OpenShift 之外公开 Kafka 集群（但甚至支持负载均衡器和节点端口）。你可以在这里阅读更多：https://strimzi.io/docs/latest/#con-kafka-listeners-deployment-configuration-kafka

【讨论】：

实际上，我第一次尝试时确实尝试过使用 srimzi，但是在尝试使用 openshift 路由访问 kafka 时得到的只是代理不可用。
说吧，你可以加入相关的slack频道或者在这里做。描述 Kafka 集群的 YAML 文件是什么？
stackoverflow.com/questions/56083914/… 这是我问的一个关于使用 hte srimzi 方法的问题，也许你可以看看它，看看你是否发现我做错了什么？我在尝试 stimzi 时使用的所有 yaml 都是我在该问题中链接的 redhat 博客中给出的。
刚刚回复了那个帖子