я использую версию spark-sql-2.4.1 с Kafka 0.10 v. Пока я пытаюсь использовать данные потребителем....

Мы написали пакетное приложение для искры (версия Spark: 2.3.0). Код выглядит следующим образом....

Я читаю из потоковых данных (значения, разделенные запятыми), используя KafkaUtils