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

У меня есть код Spark, который записывает пакет в Kafka, как указано здесь: https://spark.apache

У нас есть две InputDStream из двух тем Кафки, но мы должны объединить данные этих двух входов...

У меня установлена ​​kafka на сервере Ubuntu, а красный узел находится на моем персональном...

У меня есть KStream конвейер, который группирует по ключу, а затем через какой-то интервал окна, а...

Исполнитель Spark Structured Streaming завершается с ошибкой OutOfMemoryError Проверка выделения...

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

Я читаю одновременно 3 файла CSV построчно и отправляю их в очередь сообщений (Apache Kafka).Строки...

У нас есть входящая тема кафки с несколькими сообщениями на основе схемы Avro, сериализованными в...

Мы используем kafka KTable для агрегации, и ниже указан тип данных, которые мы получаем во входных...

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

Я искал пример, использующий Kafka Streams, о том, как сделать такого рода вещи, то есть объединить...

У меня есть потоковый запрос, сохраняющий данные в fileink. Я использую .option («стартовый набор»,...

У меня есть настоящий env с кластером машин 3 кафка, который получает много данных.Для каждой темы...

Мне нужна помощь в понимании поведения потока Kafka, когда max.task.idle.ms используется в Kafka 2

Мое потоковое приложение kafka выдает следующее исключение и умирает после того, как кластеру kafka...

Я использую последний Greenwich.SR1, который включает Spring-Cloud-Stream (версия: Fishtown.SR2) и...

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

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

У меня много сомнений, связанных с Spark + Delta. 1) Блок данных предлагает 3 слоя (бронза, серебро...

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

Я пытаюсь отправить данные из программы в защищенный кластер Kafka (EventStreams в IBM Cloud -...

Я следую за настройкой инициализации образов докера Kafka Cluster, Zookeeper, Control-center,...

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

У меня есть вопросы, связанные с дизайном 1) Ниже мой конвейер: Source-webservices ---> Kafka...