Я пытаюсь перевести реализацию Spark в Pyspark, которая обсуждается в этом блоге: https://dorianbg

Наше искровое задание - это очень простое потоковое приложение Kafka, которое потребляет пакет...

Всякий раз, когда приложение Stream Streaming пытается передать смещение Кафке, оно становится...

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

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

У меня есть приложение pyspark, которое принимает сообщения из раздела Kafka, эти сообщения...

, поэтому я борюсь с данными kafka json, используя потоковую передачу по искрам, и застрял в...

Я ищу решение для добавления значения временной метки kafka в мою схему структурированной потоковой...

Как сохранить смещение сообщения в Kafka, если я использую KafkaUtils.createDirectStream для чтения...

Мое задание зажигания работает нормально при отправке в локальный кластер искр ( spark-2.3

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

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

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

У меня есть задание Spark Streaming, которое считывает данные из разделов kafka ( один исполнитель...

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

Я пытаюсь подключить Spark Streaming к Kafka в простом приложении. Я создал это приложение на...