У меня проблема с заданием Spark Streaming, одно задание всегда находится в рабочем состоянии, а...

Использование Spark Streaming с Kafka - прямой подход - Документ Версия Spark - 2.3.2 Версия Spark...

В информатике ДНК файлы огромны (по 300 ГБ каждый, а в биобанках сотни тысяч файлов), и им нужно...

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

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

Я использую API-интерфейс kafka spark Direct, чтобы использовать тему кафки.Когда нагрузка высока,...

У меня проблемы с интеграцией искры с кафкой. Я использовал spark-streaming-kafka-0-8. Я компилирую...

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

У меня есть следующее требование Существует несколько устройств, выдающих данные в зависимости от...

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

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

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

Не уверен, правильно ли я понимаю этот вопрос: Используя KafkaUtils.createStream(), сама программа...

У меня есть дистрибутив Cloudera Hadoop, Spark и т. Д., Где версия Spark-Kafka - 0,8 (т.е....

Я настроил метрики jmx в приложении Streaming Stream.Ниже приведен код: val sc = spark.sparkContext...

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

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

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

Я работаю с Apache Spark 2.3 и читаю данные с порта UDP в формате lz0, распаковываю эти данные в...

Мой senario выглядит следующим образом: Kafka ----> spark stream (server1) -----> spark stream...

Я пытаюсь интегрировать Spark с Kafka с Python.У меня есть тема под названием mawstopic, которая...

Я разработал потоковое потоковое воспроизведение (подход с приемником), которое считывает данные из...

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

Использование spark-streaming для получения данных из Kafka и последующей записи их в HDFS в...

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