Мы планируем использовать сообщения из потока Kinesis.Нам нужно обрабатывать данные событий по одному (без окон, без агрегации), и мы могли видеть несколько опций для чтения данных из потока kinesis:
Библиотека потребителей Kinesis
Лямбда-функция
Spark / Flink Streaming на EMR
Может ли кто-нибудь рассказать о том, когда один из вариантов предпочтительнее другого?
Заранее спасибо