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

В настоящее время мы работаем на Apache Kafka 0.10.1.1.Мы переходим на Confluent Platform 5.X.Новый...

Создан поток со следующим полем CREATE STREAM pageviews_original_string(view_time string, user_id...

Я использую поток kafka для агрегирования данных и записи в другую тему. Каждые несколько минут...

Мы используем confluent платформу на Ubuntu.У нас есть простые данные JSON, отправляемые через...

Я создал тему в kafka под названием «test», в которой есть только один раздел, и он не...

Я хочу провести анализ поведения пользователя на событиях в Кафке.Может ли KSQL / Kafka Streams...

Скажем, мы должны использовать confluent-kafka-dotnet , ProducerConfig получает массив адресов...

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

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

Я хочу обработать Twitter данные, используя Apache Spark + Kafka.Я создал шаблон для этого.Но когда...

При использовании kafka-streams-scala, портирования lightbend kafka-streams-scala, в Scala 2.12 мы...

У меня задание со структурированной потоковой передачей, которое читает и записывает данные json в...

Хочу изучить распределение времени обслуживания в Кафке.На самом деле, это время обслуживания,...

Я был удивлен, увидев, что Spark получает данные из Kafka только с одним потребителем Kafka, и этот...

Я использую конфлюент Kafka-rest продукт, чтобы использовать записи из темы.Мое намерение состоит в...

У меня есть две уплотненные темы.Один содержит всю информацию о моем пользователе ( USERID ), а...

У меня есть события, приходящие в Кафку.Требуется прочитать входящие данные и получить счетчики по...

Я разработал потоковую искру (1.6.2) с Kafka в модели приемника и выполняю это задание с размером...

Моя идея такова: Сначала groupByKey, затем ip, устройство уникально, затем map [ip, device] ip -...

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

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

По умолчанию Kstream использует / tmp location для поддержания своего состояния (вида метаданных) с...

Мы столкнулись с проблемой из-за изменения API с Kafka 0.11 на Kafka 2.0.В нашем приложении потоков...

Я пытаюсь перенести мое текущее потоковое приложение, основанное на использовании RDD (из их...