Вопросы по теме 'rdd'
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
