В моем приложении после запуска я хочу использовать только те сообщения, которые были написаны до двух минут назад.Другими словами - только сообщения за последние две минуты.
Я использую nodejs и kafka-node для чтения сообщений из темы, которая имеет несколько разделов.Я использую ConsumerGroupStream для чтения моих сообщений, а затем фиксирую смещение с помощью функции ConsumerGroupStream.commit.Я не нашел упоминания о способе чтения сообщений, которые поступили после определенной отметки времени в документации.Есть ли способ добиться этого с помощью kafka-узла?