kafka – список вопросов по тегу – страница №2

Я использую JMX для мониторинга кластера Apache Kafka с помощью плагина collectd GenericJMX. Однако я не уверен, что означают некоторые параметры MBean. В частности, у меня...

Я использую JMX для сбора метрик из Apache Kafka и отправки в Librato, службу визуализации и мониторинга, через collectd. Проблема в том, что некоторые показатели, похоже...

Я написал доступную книгу, которая должна установить инструмент под названием kafkacat. Большинство задач в playbook работают, кроме одной (самой важной). Я компилирую...

внутри docker-compose.yml мы настроили следующий объем image: confluentinc/cp-kafka:latest...

Примечание: я в курсе, что есть много похожих вопросов, уже смотрел на них, не помогло. Я запускаю тестовый тест kafka в закрытой среде, я дал каждому брокеру файловую систему...

У меня есть кластер kafka с 3 брокерами, настроенный в AWS VPC с кубернетами, я использую https://github.com/Yolean/kubernetes-kafka репо для этого. У меня странная проблема с...

Учитывая хост / IP-адрес брокера, есть ли способ опросить его, чтобы узнать идентификатор брокера, кроме запроса ZK? Я пытаюсь сопоставить IP-адрес с идентификатором брокера...

Я хотел бы реализовать кафку в контейнере докера. Я также использую официальный экземпляр zookeper для kafka в качестве контейнера докеров. Когда я хочу написать сообщение о...

У меня zookeeper.version = 3.4.10, и я вижу: https://issues.apache.org/jira/browse/ZOOKEEPER-2307 это, однако, находится в нерешенном состоянии. Проблема возникла из-за...

Значение по умолчанию logs.dir=/tmp/kafka-logsв server.properties. Обычно /tmp избегают хранить какие-либо важные файлы, и мы храним сообщения и смещения! Любая конкретная...