У меня есть тема на Кафке, которую я потребляю, и я использую from_json для преобразования...

Я занимаюсь разработкой структурированного приложения Spark Stream, в котором после анализа я...

Как показано в Confluent docs при написании приложений PAPI , вы должны закрыть хранилища, которые...

У меня на Месосе работает потоковая передача искр.Все его партии занимают одно и то же время, и это...

Итак, у меня проблема с Kafka Sinks в Spark Streaming при отправке JSON для нескольких тем и...

У меня есть два структурированных потоковых приложения Spark.Первый делает несколько оконных...

Не могли бы вы разрешить мои сомнения.Я смог получить поле из jsonObject...

Мы храним смещение кафки в БД для контрольных точек.Это помогает в нулевой потере сообщений при...

Я пишу сценарий оболочки Spark и по какой-то причине мне сказали не предоставлять код в виде...

Я уже видел подобный вопрос, как нажмите здесь Но все же я хочу знать, если потоковая передача...

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

У меня есть инфраструктура AWS 1 Кластер Kafka на 3 док-контейнерах, работающий на ECS,...

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

Допустим, у нас есть экземпляр с конфигурацией, как указано ниже, и состояния, поддерживаемые в...

В настоящее время я пытаюсь переместить мои приложения Kafka в кластер Docker.Я нахожусь на CentOS...

Использование потоковой передачи Spark для чтения данных Json из раздела Kafka. Я использую...

Я создаю приложение kafka streams с помощью spring-kafka для группировки записей по ключу и...

Я использую Kafka с socket-socketIO для проекта, используя flasfka Следуя документации , я...

Из потока (k, v) я хочу вычислить поток (k, (v, f)), где f - частота появления данного ключа за...

У меня проблемы с простой потребительской программой Kafka: 18/06/04 18:13:49 ERROR /log/log.txt:...

Я пытался добавить аутентификацию SASL для моих брокеров Kafka с помощью SASL_PLAINTEXT...

Частично это продолжение Агрегирование по определенному разделу в потоках Apache Kafka Предположим,...

В приведенном ниже коде используются исходные кафки, стоковые hdfs, с использованием потоковой...

я пытаюсь определить файл docker-compose, который создает конфлюент kafka & zookeeper. кажется, что...

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