Вопросы по теме 'spark-streaming'
Как анализировать сложные данные JSON в потоковой передаче искры в Java
Мы разрабатываем IOT-приложение
Мы получаем следующий поток данных от каждого устройства, для которого мы хотим выполнить анализ,...
4589 просмотров
schedule
11.11.2023
Kafka Spark Stream выдает исключение: нет текущего назначения для раздела
Ниже приведен мой код scala для создания потока spark kafka:
val kafkaParams = Map[String, Object](
"bootstrap.servers" -> "server110:2181,server110:9092",
"zookeeper" -> "server110:2181",
"key.deserializer" ->...
3209 просмотров
schedule
11.11.2023
