Я имею дело с данными таймсерий для живого приложения. Так что старые данные не имеют значения. Я просто хочу обрабатывать данные, полученные после запуска потокового приложения, а не из ранее зафиксированного смещения. Как правильно игнорировать старые записи в приложении потока kafka после перезапуска?
В потребительском API kafka я обычно использовал метод seekToEnd() для перехода к последней записи. Есть ли эквивалентный механизм для потоков? Я хочу избежать фильтрации всех сообщений с момента последней фиксации, чтобы игнорировать старые сообщения.
