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

Как описано в Spark Structured Streaming с интеграцией Hbase , мне интересно записывать данные в...

Я пишу приложение, в котором пытаюсь подсчитать количество пользователей, которые посещают страницу...

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

У меня давно запущено искровое потоковое задание, которое читает с кафки. Это задание запускается...

У меня матрица с 3 заказчиками, но проблема в том, что когда я останавливаю контейнер заказов,...

Иногда я нахожу исключение UNKNOWN_PRODUCER_ID при использовании потоков kafka. 2018-06-25 10:31:38

Мы агрегируем в окнах сеансов, используя следующий код: .windowedBy(SessionWindows.with(...))

Я хочу спросить, что именно setMaster("local[2]") и Map("test1"->5) означает...

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

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

Я использую низкоуровневый API-процессор.У меня есть тема с 6 разделами.В классе, который реализует...

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

Я работаю над потоковой передачей Kafka Spark с использованием Java, когда я выполняю writeStream...

Что означает, что в столбце CURRENT-OFFSET отображается "-"? TOPIC PARTITION CURRENT-OFFSET...

У меня есть Kafka Consumer со временем опроса, указанным как kafkaConsumer

Я запускаю запрос на структурированную потоковую передачу в формате Spark следующим образом: val...

У меня проблема с пробелами в именах при использовании EXTRACTJSONFIELD в KSQL Например: SELECT...

У меня есть структурированный поток данных tempDataFrame2, состоящий из Field1.Я пытаюсь вычислить...

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

Могут ли два параллельных процессора в топологии выполнять установку / загрузку в одном глобальном...

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

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

Я создаю ниже KafkaDirectStream. val messages = KafkaUtils.createDirectStream[String, String]( ssc,...

У меня есть приложение Kafka и Spark для структурированной потоковой передачи.В частности, у меня...