У меня есть задание, которое получает данные от Kafka каждые 10 секунд, а затем я форматирую данные и вставляю их в cassandra, но это очень сбивает с толку, что моя работа становится все медленнее и медленнее. Согласно моей статистике, каждые 10...

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

Я ищу коннекторы Spark Streaming + Accumulo и пример полного использования. В настоящее время я пытаюсь записать результаты потоковой передачи Spark в таблицу Accumulo, но получаю NotSerializableException для BatchWriter. Может ли кто-нибудь...

У меня проблема, связанная с Кафкой. У меня есть текущая служба ( Producer ), которая отправляет сообщение в тему Kafka ( events ). Сервис использует kafka_2.12 v1.0.0 , написанный на Java. Я пытаюсь интегрировать его с примером проекта...