Я использую поток Кафки для некоторых приложений. Поток потока, как показано ниже...

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

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

Получаю приведенную ниже ошибку при потоковой передаче искры.Это работает отлично в течение...

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

Я пытаюсь написать простое приложение Kafka Streams (нацеленное на Kafka 2.2 / Confluent 5.2),...

Я пытаюсь разделить поток сообщений из одной темы Kafka по значению столбца, используя Spark...

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

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

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

Я довольно новичок в структурированном потоковом вещании Spark и пытаюсь объединить несколько...

Можно ли использовать одну и ту же привязку для создания сообщений через Kafka Producer и для...

Я занимаюсь разработкой приложения (на основе микросервисов), опираясь на Kafka и Kafka Streams. Я...

Я довольно новичок в Python и начинаю работать с Kafka.Итак, я настроил брокера Kafka и пытаюсь...

Я следую этому учебнику . И в соответствии с инструкциями я скачал платформу с здесь и клонировал...

Я работаю над управлением окнами потоков kafka, в частности, окнами для моего варианта...

У меня проблемы с попыткой добиться следующего через Kafka Streams: При запуске приложения (сжатая)...

Я отправил postgres wallog на kafka, каждая таблица - тема.Схемы тем похожи на следующие (вложенный...

Я использую Spark Structured Stream для чтения сообщения от Kafka. Сообщения содержат путь к...

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

Жалуется, если в конфигурации не указан источник. Согласно документу: Канал Кафки может...

Я читаю 2 потока (stream1 & stream2) из ​​Kafka в потоковой структурированной искре (pyspark). Я...

Spark (v2.4) Функция программы: Чтение данных JSON из Kafka очереди в режиме структурированной...

При получении вывода из потока kafka logstash также отображает другие символы.(\ u0018, \ u0000, \...

Мое требование - прочитать объекты json из kafka и для каждой записи выполнить поиск в кэше redis и...