Я работаю над приложением, которое считывает и обрабатывает события из AWS Kinesis Stream с помощью клиентской библиотеки Kinesis (KCL). Я не хочу, чтобы сторона производителя событий страдала от задержки, поэтому для отправки событий использовался KinesisAsyncClient. Однако, чтобы моя обработка событий работала правильно, мне нужно обрабатывать события в «порядке, который я назвал putRecordAsync» на стороне производителя. Эта информация доступна в виде поля метки времени внутри каждой записи Kinesis.
Помимо переключения на использование блокирующего синхронного клиента Kinesis, возможно ли какое-либо другое решение для эффективной сортировки потоковых событий?