Я знаю, что если у нас будет несколько разделов и почти одинаковое количество потребителей в группе...

Я строю простой проект с Spring Boot и Spring-Kafka, я не могу настроить его, чтобы он работал, это...

Я написал модуль узла для подключения к Kafka. kafka-connect.js var kafka =...

У меня есть сценарий, в котором мой первый болт в топологии - десериализация сообщения из темы...

Я довольно новичок в NiFi и Kafka, и я боролся с этой проблемой в течение нескольких дней.У меня...

У меня есть 2 разных сообщения-экземпляра приложения, использующих тему, оба приложения имеют...

Мне нужно реализовать потоковое видео с помощью kafka. Я могу транслировать видео в браузер с...

Существует проблема построения системы на основе стека RDBMS / Kafka / Ni-Fi / Sqoop / Hadoop-Hive....

У нас есть Jolokia в качестве агента JMX для получения метрик Kafka, мы хотим получить Per Topic...

У меня есть несколько коннекторов и разделов Kafka, в которых размещены разные источники данных, но...

Я пытаюсь найти способ / помощника для преобразования .Net Class в Avro.Generic.GenericRecord.В...

Я не могу заставить Spring-Kafka работать с клиентскими версиями Kafka 1.x.Я получаю приведенную...

Привет, я пытаюсь переместить данные в формате csv из kafka в hdfs, используя соединитель приемника...

У меня есть KafkaConsumer, который вызывает метод подписки для определенной темы (например, topic1)

Я пытаюсь включить SSL-аутентификацию на моем сервере Kafka.Я следую разделу 7.2 в нижеприведенной...

Есть ли способ узнать версию Kafka вне кластера?(возможно, с помощью telnet или другого...

Получение следующей ошибки (Kafka 2.1.0): 2018-12-03 21: 22: 37.873 ОШИБКА 37645 ---...

Я пытаюсь преобразовать тестовый образец Java в тестовый образец Scala, но, похоже, что-то не...

Есть ли какие-либо существенные недостатки, когда я устанавливаю время хранения определенной темы,...

У нас есть 3 сервера zookeepers и 6 машин Kafka.Что может случиться, когда один сервер zookeeper...

6 машин kafka (это физические машины - DELL HW) 3 сервера zookeeper мы хотим добавить 12 машин...

Когда я передаю или транслирую две и три таблицы, я могу легко отобразить в Elasticsearch, но могу...

Я недавно читал об очередях сообщений.Поскольку я новичок в этой теме, я не смог определиться с...

Я использую KafkaConsumer со следующими настройками enable.auto.commit = true auto.commit.interval

Я пишу Kafka Producer, который использует HDFS INotify API для мониторинга определенного каталога и...