Долгое время Кафка пытается избавиться от Zookeeper. Является ли использование Zookeeper устаревшим...

У меня есть случай, когда я хочу прочитать данные из Kafka в пакетном режиме, используя Apache Beam...

Я просмотрел множество примеров для чтения данных JSON из темы Кафа. Мне удалось сделать это...

Я создал приложение IOT на основе колб, где устройства регулярно отправляют данные через API REST,...

Как я могу найти коэффициент потребления? т. е. количество событий / байтов не принимается каждую...

У меня есть группа потребителей kafka, работающая на node.js и работающая на node-kafka. Когда эта...

Я пытаюсь получить данные от производителя kafka в hdfs в структурированном spark с помощью pyspark

У меня есть кластер Kafka, который работает на K8S. Я использую слитное изображение Кафки, и у меня...

Я использую kafka для получения данных на потоковый процессор WSO2 в формате Json, но я получаю...

Используя Spring cloud Stream 2.1.4 с Spring Boot 2.1.10, я пытаюсь настроить таргетинг на...

В настоящее время я оцениваю варианты проектирования / реализации архитектурного подхода Event...

Это в качестве ссылки, поток обновлений профиля хранится в объекте KTable. Как долго эти данные...

Я разрабатываю нижеприведенную архитектуру: 1) flume agent_a подгоняет текстовые файлы в каталоге...

Я настроил Spark структурированный потоковый запрос, который читает из темы Kafka. Если количество...

Когда мы пытаемся передать данные из раздела Kafka с поддержкой SSL, мы сталкиваемся с ошибкой ниже

Моя главная цель - получить смещение, которое kafka использует для отправки каждой записи, и...

Мы создаем приложение для получения данных с датчиков. Данные передаются в Kafka, откуда...

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

Я думаю сделать следующее. В Topic1 есть данные JSON Пример: {"name":"alice"...

Можно ли запросить KSQL KTable по ключу из отдельного приложения KStreams? Или, другими словами,...

Мы установили центр управления документооборотом док-станции следующим образом: $ docker run -d \...

У меня есть топология, в которой я использую Transformer для агрегирования своих объектов, позже в...

Я работаю над потоковой передачей Kafka и пытаюсь интегрировать ее с Apache Spark. Однако во время...

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

Я обрабатываю входящие объекты из потоковой среды, собираю и печатаю их. Использование подавления...