например. У меня есть тема «тест» с 4 разделами. Когда я запускаю потоковое приложение, и через некоторое время приложение вылетает. Я хочу указать смещение для потребления. Я хочу использовать данные из смещения послепоследнее чтениеНо я не могу найти ничего, что могло бы помочь достичь этого с помощью API kafka-streams.
PS Мы используем kafka-2.1.0