Описание тега strimzi

Strimzi - это проект с открытым исходным кодом, позволяющий Apache Kafka работать в контейнерах, таких как Kubernetes и OpenShift.
1 ответ

Настройка кластера Kafka-zookeeper в Prometheus Discovery(с использованием кластера Strimzi Kafka)

У меня работает кластер Kafka-zookeeper с использованием кластер-оператора Strimzi. Я следовал за КБ http://strimzi.io/docs/master/ для этого. Метрики для kafka и zookeeper доступны через порт 9404. Я должен настроить эту настройку кластера на Prome…
23 сен '18 в 05:01
0 ответов

Оператор темы Strimzi: тема уже создана

Мы используем Strimzi 0.8.2 для управления Kafka в кластере Openshift. Чтобы протестировать Kafka Connect, мы используем контейнер Confluent Docker локально (пока еще не в кластере). Прежде чем добавить новый соединитель, я создаю тему, например "my…
19 дек '18 в 12:52
1 ответ

OpenShift / OKD Укажите URL для каждой реплики Pod

Я новичок в Открытой смене / ОКД. Я бегу Стримзи на вершине открытой смены. Я развернул приложение, которое включает в себя Rest API. Это приложение имеет Rest Api, и можно контролировать производителя и потребителя от остальных Api. Я скопировал PO…
1 ответ

"нет совпадений для доброй" Кафки "в версии"kafka.strimzi.io/v1alpha1" "

При попытке установить кластер Kafka с помощью оператора Strimzi возникает следующая ошибка Действия по воспроизведению: 1) установить olm: kubectl create -f https://raw.githubusercontent.com/operator-framework/operator-lifecycle-manager/master/depl…
21 мар '19 в 02:55
1 ответ

Настройка Кафки на Openshift с помощью стримзи

Я пытаюсь настроить кластер kafka на платформе Openshift, используя это руководство: https://developers.redhat.com/blog/2018/10/29/how-to-run-kafka-on-openshift-the-enterprise-kubernetes-with-amq-streams/ Мои кластеры zookeeper и kafka работают так,…
1 ответ

Разоблачение метрик Кафки Прометею и Графане на Ранчере

У меня установлен Strimzi Operator в моей среде Rancher Kuberenetes, работающей на AWS. Я использовал оператор Strimzi для развертывания моего кластера Kafka с 3 брокерами. Мой кластер работает нормально, и я могу производить и потреблять. Теперь я …
05 авг '19 в 16:09
0 ответов

Не работает оператор темы Strimzi - Openshift

Я развернул оператор темы Strimzi в openshift, используя следующую документацию: https://strimzi.io/docs/0.12.2/full.html. Это не работает, и ошибка показана ниже: 2020-02-26 13:40:30 INFO ZooKeeper:100 - Client environment:java.library.path=/usr/ja…
1 ответ

Strimzi: MirrorMaker 2.0 подключается к IBM EventStream

Я настроил Kafka на Kubernetes с помощью Strimzi. Я попытался подключить Kafka к IBM EventStream через MM2, но получаю ошибку.. Любые мысли, какое сообщение и тема вызывают проблемы 2020-03-09 17:25:40,258 ОШИБКА Неперехваченное исключение в вызове …
09 мар '20 в 20:30
0 ответов

Статус развертывания kubectl для kubernetes CRD завершается с ошибкой "ошибка: невозможно декодировать файл"

Я использую Strimzi для развертывания Kafka на Kubernetes https://strimzi.io/ Я использую последнюю версию Strimzi который v0.19.0, Kubernetes version: v1.16.13-gke.1 на GCP-GKE и kubectl version: v1.19.0 Я пытаюсь проверить, завершено ли масштабиро…
2 ответа

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

У меня успешно настроен кластер Strimzi Kafka на OpenShift. Я вижу следующие услуги: kafka-brokers kafka-bootstrap zookeeper-client zookeeper-nodes Это на самом деле отличается от того, что выкрикнул здесь; так что не уверен, если это проблема устан…
03 окт '19 в 18:25
2 ответа

Стримзи - Подключение внешних клиентов

Следуя обсуждению здесь, я использовал следующие шаги, чтобы подключить внешний клиент (на основе kafkajs) к Strimzi в OpenShift. Эти шаги отсюда. Включить внешний маршрут В kafka-persistent-single.yaml редактируется как показано ниже. apiVersion: k…
2 ответа

Как использовать Strimzi Kafka Bridge в качестве потокового сервиса

Используя мост Strimzi Kafka Bridge от CNCF, я создал небольшой API, который может взаимодействовать с сервером Kafka с использованием протокола HTTP/1.1. Все это хорошо для сценария запрос-ответ. Однако мое требование состоит в том, чтобы передават…
05 окт '19 в 01:49
1 ответ

Как открыть конечную точку HTTPS с помощью strimzi-kafka-bridge?

Я могу настроить мост и подключиться к существующему кластеру Kafka и читать данные с помощью HTTP-запросов. Есть ли способ добавить уровень безопасности и предоставить конечную точку HTTPS для получения записей Kafka вместо обычного HTTP? У меня ес…
13 ноя '19 в 21:35
1 ответ

Реализация Apache Strimzi Kafka Bridge

Это очень общий вопрос к сообществу, особенно к людям из Моста Кафки Стримзи, если они это читают. Я пытаюсь реализовать их HTTP-мост Apache Kafka в качестве POC для чего-то. Документация очень плохая и не дает никакой помощи. Мне просто нужно знать…
02 окт '19 в 05:32
1 ответ

OpenShift - когда создается служба при создании нового приложения?

Я создал два приложения wurstmeister/kafka а также zookeeper как показано ниже. oc new-app wurstmeister/kafka oc new-app zookeeper Пока я вижу zookeeperservice в моем проекте, службу Kafka не вижу. Как подключить другие модули к Kafka? Через IP-адре…
03 окт '19 в 08:41
1 ответ

strimzi 0.14: сбой аутентификации брокера Kafka

Я попытался построить кластер Kafka с помощью Strimzi (0.14) в кластере Kubernetes. Я использую примеры, поставляемые с strimzi, т.е. examples / kafka / kafka-persistent.yaml. Этот yaml-файл выглядит так: apiVersion: kafka.strimzi.io/v1beta1 kind: K…
31 окт '19 в 21:46
0 ответов

Невозможно подключить производителя / потребителя к облачному брокеру kafka после развертывания на k8s с помощью strimzi

Я не могу заставить продюсера писать на тему кафки. Моя служба кафка была развернута на k8s с помощью strimzi. Мой кластер k8s имеет 2 узла в облачной службе Google. Как видно из конфигурации k8s, все службы включены: В kafka-cluster-kafka-external-…
1 ответ

Как запустить kafka Producer.sh и consumer.sh для конкретного пользователя для проверки ACL?

./bin/kafka-console-producer.sh --broker-list 10.162.0.6:32294 --topic my-topic ./bin/kafka-console-consumer.sh --bootstrap-server 10.162.0.6:32294 --topic my-topic --from-beginning Я новичок в кафке. Моя кафка работает на операторе strimzi kubernet…
2 ответа

Инструменты пользовательского интерфейса для подключения к кластеру strimzi kafka

Ищу инструменты пользовательского интерфейса для подключения к кластеру Strimzi kafka, чтобы получить видимость тем kafka, читать сообщения в темах, сведения о брокере и разделах, а также возможность подключаться с или без подключений SSL/SASL. Я уж…
02 июл '20 в 22:10
1 ответ

Как включить метрики JMX для моста Стримзи-Кафка

Я включаю порт JMX для моста Strimzi-Kafka, добавляя эти строки в файл Kafka-Bridge.sh. -Dcom.sun.management.jmxremote.port=9250 -Dcom.sun.management.jmxremote.rmi.port=9250 -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxr…
06 мар '20 в 14:45