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

на всех наших машинах kafka (производственных машинах) мы видим, что: (нет свободного места) df -h /var/kafka...

У меня в миникубе настроена кафка. Он запущен и работает, и я могу создавать в нем сообщения и потреблять их обратно. Однако, когда я вхожу в систему с одним брокером...

мы хотим установить кластер kafka и 3 сервера zookeeper kafka должен использовать серверы zookeeper, чтобы сохранять метаданные на серверах zookeeper Файлы данных и журнала ZK...

У меня есть установка kafka (с ssl listener и ssl-аутентификацией клиента). Он работает нормально, пока я не попробую добавить ACL. это ошибка (полная ошибка внизу): [edit-1]...

Я использую rsyslog для отправки данных из nginx в kafka. Конвейер выглядит следующим образом: nginx -> unix_socket -> rsyslog -> omkafka module -> kafka...

Сценарий: кластер Kafka, защищенный шифрованием SSL и аутентификацией SASL / PLAIN, находится в частной подсети AWS в выделенном VPC. В частной подсети все в порядке. Я...

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

Обычно я проверял список групп потребителей с помощью команды "kafka-consumer-groups.sh" в Linux. Теперь я хочу получить результат на машине с Windows. Я заметил, что двоичные...

У меня странная ситуация. Мой Confluent Kafka Connect S3 обрабатывает около 8К сообщений в секунду. Что началось случайно каждые несколько дней это: Класс Fetcher попытается...

У меня есть определение задачи под названием kafka-zookeeper, в нем есть брокер Apache Kafka и узел Zookeeper. Эти контейнеры должны взаимодействовать друг с другом (это легко)...