Из-за того, что структурированные потоки Spark являются довольно новым API, возникают ситуации, когда вам приходится возвращаться к более старому потоковому API. Например, на данный момент у вас есть выбор: AWS Kinesis + старый потоковый API против Kafka + новый потоковый API.
Есть ли какие-либо сравнения производительности старого и нового потокового API Spark? Сколько раз новый API лучше? Задержка, пропускная способность ...