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

Чтобы сделать наш кластер Kafka доступным как из Интернета, так и из нашей частной сети, мы решили настроить Kafka следующим образом: Private VIP:9000 => All brokers:9092...

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

У нас есть 3-узловой кластер Kafka с коэффициентом репликации 3 и сроком хранения журналов по умолчанию 4 дня. Мы включили автоматическое создание тем, и оно будет создавать...

У меня есть среда, в которой logstash (v6.2.3) подключает кластер kafka_2.11 (v.1.1.0) с использованием ввода kafka. Я хочу получить информацию о смещении потребителя...

на всякий случай удаляем не ту тему как /usr/hdp/current/kafka-broker/bin/kafka-topics.sh --zookeeper hdpmaster01:2181 --delete --topic gtom.poli.pri.proc...

package org.apache.spark.examples.kafkaToflink;...

У меня есть машина Ubuntu 16.04, на которой установлен Apache Kafka. В настоящее время я могу заставить его работать безупречно, используя start_kafka.sh скрипт со следующим...

Я пытаюсь установить syslog-ng и его модуль kafka. Я использую docker debian: latest для этого, если это важно. После запуска 'apt-get install syslog-ng' syslog-ng не может...

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

Нам нужно создать xfs файловая система на kafka диск Особенность в kafka disk размер диска kafka диск есть 20TB размер в нашем случае Я не уверен в следующем mkfs , но мне...