Я использую Spark Structured Streaming, которая считывает данные из Kafka, используя Java API.
Однако для конкретного условия необходимо прочитать данные из MySQL.
Как это можно реализовать с помощью структурированной потоковой передачи?
Подробнее здесь: https://stackoverflow.com/questions/795 ... mysql-read
