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

Я настроил Spark Structured Streaming (Spark 2.3.2) для чтения из Kafka (2.0.0). Я не могу...

Я использую режим пряжи и кластера, версия streaming-kafka - 0.10.Тем не менее, следующие ошибки...

Среда: Spark 2.3.0, Scala 2.11.12, Kafka (Какая бы ни была последняя версия) У меня есть безопасная...

В моей программе spark у меня есть этот код: val df = spark.readStream .format("kafka")

Kafkaconsumer небезопасен для многопоточного доступа 4 ответа Kafka - это источник данных для...

Невозможно сохранить сообщения Avro в потоковый фрейм данных spark / scala в версии spark 2.0.2.Как...

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

Для приложения My Spark 2.4.x (pyspark) требуется: Входные данные - это две темы Kafka, а выходные...

Время выполнения Режим кластера YARN Приложение Структурированная потоковая передача Spark Чтение...

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

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

Spark 2.4.0 поддерживает Python UDF с режимом непрерывной обработки? В моем простом коде я...

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

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

Здесь я отправляю данные json в kafka из темы «test», передаю схему json, выполняю некоторые...

Я экспериментирую с режимом непрерывной обработки Spark в структурированном потоке и читаю тему...

В нашем приложении spark мы используем поток Kafka и храним данные в Cassandra DB. Во-первых, мы...