Как мне установить spark задание для получения kafka topic из specific offset на основе timestamp?...

Я использую Streaming для получения записей о звонках от брокера Kakfa каждые 10 минут. Я хочу...

Я хочу для потоковой передачи данных, используя спарк из темы Кафки в Horton works. Я запустил...

Я пытаюсь выполнить запрос в Neo4j, используя соединитель Neo4j-Spark. Я хочу передать значения из...

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

У меня есть тема Кафки t1, которая содержит 100 сообщений. После операции flatMapValues ​​()...

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

У меня есть тема Kakfa, в которой данные хранятся в формате JSON. Я написал код потокового...

Pyspark новичок. Получение ошибки при выполнении работников pyspark. Сценарий Pyspark: import os os

Я пытаюсь рассчитать окно с примером количества слов. Он работает нормально, за исключением того,...

Я почти уверен, что не существует простого способа сделать это, но вот мой вариант использования: У...

Я новичок в работе со scala, и при попытке запустить этот простой код, который пытается прочитать...

Я использую librdkafka для написания .net-клиента kafka на windows, который подключается к кластеру...

Я делаю простой код, который: Создает брокера kafka, используя docker Публикация сообщений с...

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

В соответствующей документации kafka сказано, что класс Consumer определен следующим образом: Class...

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

Я пытаюсь отправить приложение spark на отдельную виртуальную машину кластера spark (2.1.1),...

Я пытался использовать Kafka, используя Spark, а точнее PySpark и Structured Streaming. import os...

Примеры github page для библиотеки Confluent Kafka содержат два метода, а именно опрос и...

Я выполнил код Scala в IntelliJ IDEA для spark.streaming.kafka, где я использую scala версии 2.11,...

Я использую Kafka Streams с Spring Boot.В моем случае использования, когда я получаю событие...

Мне нужно прочитать зашифрованное сообщение из темы Кафки.Мой текущий код, который читает строки из...

Я пытаюсь добавить источник подключения jdbc через Confluent Control Center.Я заполнил все...

Я тестирую потоковую передачу данных с использованием Kafka, Druid и SuperSet. Я нахожусь в точке,...