У меня проблема с широковещательной переменной при интеграции kafka и spark streaming. Если я не...

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

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

У меня есть небольшой искровой кластер с одним мастером и двумя рабочими. У меня есть потоковое...

Интересно, есть ли где-нибудь список всех свойств, связанных с потоковой структурой с искрой?...

Интересно, есть ли способ указать размер мини-партии в структурированной потоковой передаче Spark....

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

Я использую спарк для получения данных из темы кафка. Я должен deserialaizer avro данных с...

Я собрал клиента Kafka, который извлекает данные из записи Kafka в Elasticsearch, программа...

Я пытаюсь прочитать данные из Kafka (1 тема, 5 разделов), используя подход Spark Streaming Direct....

Я новичок в Streaming Framework Spark и пытался обработать поток Twitter. Я нахожусь в процессе...

Я просто пытаюсь запустить пример кода Statefu lstreaming, но он завершается ошибкой. Не могу...

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

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

В моем приложении для потокового вещания я передаю свои правила слюни, которые имеют вид объекта...

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

Посмотрите на мой последний комментарий принятого ответа для решения Я настроил DStream так: val...

У меня есть простое приложение Spark Streaming в Spark версии 2.3.0, которое помещает результаты...

у меня струится искра (2.1.1 с cloudera 5.12). с входной кафкой и выходной HDFS (в формате паркета)...

Мы пишем приложение Stream Streaming, чтобы читать сообщения kafka методом createStream, и интервал...

1 потоковое и Kafka брокер версии 0.8.2.1, у меня есть отдельные серверы для спарк и кафка на AWS....

есть hashMap parsedRecord, тип которого scala.collection.immutable.HashMap , способ получения типа:...

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

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

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