Я играл с потоками данных Kinesis, и мне было интересно, как веб-приложение или мобильное приложение будет отправлять события в потоки данных Kinesis. Один из способов сделать это - установить конечную точку на основе java пружины, в которую веб-приложение или мобильные приложения будут отправлять сообщения, и сервер будет собирать / собирать записи с использованием KPL. Другой способ - отправлять события в промежуточное хранилище, например sqs или базу данных, а затем отправлять их в потоки данных kinesis через лямбду. Но в обоих случаях я чувствую, что промежуточный шаг уменьшает сущность потоков данных в режиме реального времени. У кого-нибудь есть мысли / опыт по такому сценарию?