OpenShift - Невозможно подключить стримзи из KafkaJS

Question

У меня успешно установлен кластер Strimzi Kafka в OpenShift. Я вижу следующие услуги:

• kafka-brokers
• kafka-bootstrap
• zookeeper-client
• zookeeper-nodes

Это на самом деле отличается от того, что здесь вызывается ;так что, не уверен, если это проблема установки Strimzi. Я следовал инструкциям по установке здесь .

Я создал маршруты для kafka-bootstrap и kafka-brokers на порту 9092 (клиенты без TLS). В обоих случаях я получаю ошибку ECONNREFUSED, когда я указываю значение маршрута (например, my-cluster-myproject.192.168.99.100.nip.io:9092 в примере из kafkajs .

Как подключить пакет kafkajsв кластер Стримзи?

Answer 1

Сервисы Strimzi, которые вы видите, правильные, но для доступа к брокерам Kafka лучше использовать сервис начальной загрузки, который позволяет указать только одного «брокера» в списке серверов начальной загрузки вашего клиента, и он выберет брокера. подключиться в первый раз, а затем получить метаданные (это позволяет избежать подключения с помощью службы безголового доступа, где IP-адреса модуля могут изменяться при перезапуске). То есть, если вам нужен доступ к брокерам извне OpenShift, вам не нужно вручную создавать маршрут для службы начальной загрузки, но вам нужно настроить внешние прослушиватели (https://strimzi.io/docs/latest/#assembly-configuring-kafka-broker-listeners-deployment-configuration-kafka) с типом route. Как уже упоминалось выше, маршруты OpenShift работают с TLS только для TCP-соединений. Чтобы предоставить своим клиентам правильный сертификат для использования TLS, вы можете следовать этой части документации: https://strimzi.io/docs/latest/#kafka_client_connections

Answer 2

Вы проверили внешних слушателей ?

Кстати, если вам нужно выставить стримзи маршрутизатором, необходимо шифрование TLS. Маршрутизатор OpenShift не поддерживает TCP, но поддерживает TLS.