У меня есть тема kafka, по которой я отправляю данные через Kafka Producer. Теперь на стороне...

У меня есть приложение для потокового воспроизведения, которое запускается в конце дня и использует...

Часть моей искровой работы: val kafkaParams = Map[String, Object]( "key.deserializer"...

У меня есть следующий код: - val conf = new SparkConf() .setAppName("Data")

Я написал код для извлечения записей из кафки в спарк.Я столкнулся с каким-то странным поведением

Я пытаюсь провести простой тест, в котором я использую Kafka-connect и spark Я написал...