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