Внешний доступ к Кафке на Openshift - PullRequest
Новая
       24

Внешний доступ к Кафке на Openshift

0 голосов
/ 14 мая 2019

Я пытаюсь использовать этот метод развертывания 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

Что мне здесь не хватает, как я могу получить внешний доступ к Kafka в Openshift?

1 Ответ

0 голосов
/ 14 мая 2019

Если вы хотите упростить способ сделать это, вы можете попробовать проект Strimzi (https://strimzi.io) для развертывания и управления кластером Apache Kafka в Kubernetes и OpenShift. Он предоставляет действительно простой способ разоблачения Kafkaкластеризоваться вне OpenShift с использованием маршрутов (но даже с поддержкой балансировщиков нагрузки и портов узлов). Подробнее можно прочитать здесь: https://strimzi.io/docs/latest/#con-kafka-listeners-deployment-configuration-kafka

...