У меня проблемы с работой центра управления.Настроил 3-х узловый кластер kafka, используя следующий образ докера = confluentinc / cp-enterprise-kafka.На отдельном компьютере я скачал платформу Confluent v5.0.1 и настроил (попробовал) центр управления для мониторинга докерного кластера.
Брокер kafka, который я использую для настройки центра управления, - этото же самое с загруженной платформы v5.0.1. (Я запускаю весь стек через bin / confluent start)
Но я продолжаю получать страницу запуска ракеты, когда нажимаю Мониторинг> Состояние системы.
Моя настройка: --------------------------------------------------------
- 3-узловый кластер kafka с использованием образов докера.
- использованный образ докера = confluentinc / cp-enterprise-kafka
Кафка, работающая на этих именах хостов для 3-узлового кластера:
- os0 /, работающая на tcp / 29092
- os1 /, работающая на tcp / 39092
- os2 / работает по tcp / 49092
Центр управления работает на отдельном компьютере, имя хоста которого = sb1
Кроме того, брокеры имеют следующие директивы, определенные как:
- metric.reporters = io.confluent.metrics.reporter.ConfluentMetricsReporter
- confluent.metrics.reporter.bootstrap.servers = sb1: 9092
Дляcontrol-center Я добавил конфигурацию кластера из 3 узлов:
- confluent.controlcenter.kafka.osd.bootstrap.servers = os0: 29092, os1: 39092, os2: 49092
Я ожидаю, что брокеры kafka пишут в тему kafka broker @ sb1 (используется control-center) _confluent-metrics
Что я пробовал / проверял / отлаживал до сих пор:
- выбросил тему _confluent-metrics, и у меня там пишутся сообщения
- Я не знаю, регистрируются ли журналы из control-center (@ /tmp/confluent.QJ2C4BmE/control-center/control-center.stdout) действительно показывает что-нибудь полезное (по крайней мере, для того, что я могу интерпретировать)
- Я вижу HTTP / 200 для кластера, который я пытаюсь отслеживать, записанного в блоге.
- в журнале от брокеров Kafka Я также вижу написано следующее, котороеНапомню, что сообщения были написаны в теме: [2018-12-15 07: 57: 59,893] ОШИБКА Не удалось отправить метрики в тему Kafka __confluent.support.metrics (из-за исключения): java.util.concurrent.ExecutionException:org.apache.kafka.common.errors.TimeoutException: срок действия 1 записей для __confluent.support.metrics-0: 30083 мс прошло с момента создания пакета плюс время ожидания (io.confluent.support.metrics.submitters.KafkaSubmitter)[2018-12-15 07: 58: 01,088] ИНФОРМАЦИЯ Успешно отправленные метрики в Confluent через безопасную конечную точку (io.confluent.support.metrics.submitters.ConfluentSubmitter)
Мне не хватает жизнеспособных решений дляотладка, любая помощь будет оценена.
заранее спасибо.