Вопросы с тегом apache--spark-apache--kafka

0 голосов

1 ответ

Как сделать потоковую передачу искры в каждой партии при ограничении размера партии Kafka?

DennisLi / 04 мая 2020

0 голосов

1 ответ

Ошибка при подключении искровой структурированной потоковой передачи + кафка

Luan Carvalho / 03 мая 2020

0 голосов

1 ответ

Получение ошибки: Исключение в потоке "main" java .lang.NoClassDefFoundError: org / apache / spark / SparkConf

Harsh Somani / 01 мая 2020

1 голос

1 ответ

Пример запуска Spark: ClassNotFoundException: org. apache .kafka.common.serialization.StringDeserializer

Daniel Germain / 30 апреля 2020

0 голосов

1 ответ

Spark Streaming handle Перекошенные перегородки Kafka

dunlu_98k / 30 апреля 2020

0 голосов

1 ответ

Как применить схему Spark к запросу на основе имени Kafka topi c в структурированной потоковой передаче Spark?

TechnocratSid / 29 апреля 2020

0 голосов

1 ответ

Как сделать так, чтобы спарк-структурированный поток обрабатывал все данные в kafka

Jeremie Piotte / 29 апреля 2020

2 голосов

0 ответов

Spark структурированный поток с аутентификацией Kafka SASL / PLAIN

user152468 / 28 апреля 2020

1 голос

1 ответ

Как контролировать количество записей при записи Spark Dataframe в Kafka Producer с помощью Spark Java

user1326784 / 27 апреля 2020

0 голосов

1 ответ

Как изменить каталог кэша .ivy2 по умолчанию на что-то другое?

INT_MAX / 24 апреля 2020

1 голос

1 ответ

Как мне прочитать одно и то же начальное смещение в каждой микропакете в задании потоковой передачи с искрой

conetfun / 23 апреля 2020

0 голосов

0 ответов

Лучшая стратегия дедупликации для использования с искрой

Piyush Kumar / 22 апреля 2020

0 голосов

2 ответов

PySpark структурированная ошибка Streaming + Kafka (вызвано: java .lang.ClassNotFoundException: org. apache .spark. sql .sources.v2.StreamWriteSupport)

Petro Hupalo / 22 апреля 2020

1 голос

0 ответов

Как оптимизировать задержку в работе Spark Streaming при чтении данных из Kafka?

Alex / 22 апреля 2020

2 голосов

0 ответов

Spark Streaming: многие партии в очереди после долгого времени работы без проблем

D. Müller / 21 апреля 2020

0 голосов

1 ответ

Как сбросить искровые структурированные потоковые данные до последнего доступного смещения

Alchemist / 18 апреля 2020

0 голосов

1 ответ

Как написать Kafka Producer в Scala

Deepak Garg / 18 апреля 2020

0 голосов

1 ответ

Spark Structured Streaming с интеграцией реестра схем для сообщений на основе Avro

Ajith Sasidharan / 18 апреля 2020

0 голосов

0 ответов

Spark Структурированное потоковое приложение зависло с удаленной трансляцией

Alchemist / 18 апреля 2020

0 голосов

1 ответ

java .lang.NoSuchMethodError: org. apache .spark.internal.Logging. $ Init $

naina / 16 апреля 2020

0 голосов

0 ответов

Исключение в потоке "streaming-start" java .lang.NoClassDefFoundError: org / apache / spark / kafka010 / KafkaConfigUpdater при использовании предварительного просмотра Spark 3.0.0

sathvik vutukuri / 15 апреля 2020

0 голосов

1 ответ

Кафка читать MyClacc

Vladimir / 14 апреля 2020

1 голос

1 ответ

kafka kafka-consumer-groups. sh --describe не возвращает выходные данные для группы потребителей

wyx / 14 апреля 2020

0 голосов

1 ответ

Spark Structured Streaming чтение из нескольких тем Kafka с несколькими потоками чтения

Dhatri / 13 апреля 2020

1 голос

1 ответ

Искра Оптимизация производительности Структурированная потоковая Kafka

wyx / 13 апреля 2020