Проблема обработки данных файла в кафку, а это вызывает структурированную потоковую передачу
#pyspark #apache-kafka #spark-structured-streaming Вопрос: Я пытаюсь создать файл для кафки, а затем использовать его в потоковой передаче spark. historical_data_level_1.json -> producer.py ->> consumer.py Проблема в том, что, когда сообщения поступают…